public class DynamicPageBuilder extends Object implements AutoCloseable
Modifier and Type | Method and Description |
---|---|
void |
addRecord() |
void |
close() |
DynamicColumnSetter |
column(org.embulk.spi.Column c) |
DynamicColumnSetter |
column(int index) |
protected DynamicColumnSetter |
columnOrNull(int index) |
protected DynamicColumnSetter |
columnOrNull(String columnName) |
DynamicColumnSetter |
columnOrSkip(int index) |
DynamicColumnSetter |
columnOrSkip(String columnName) |
static DynamicPageBuilder |
createWithTimestampMetadata(String defaultZoneString,
Map<String,org.embulk.config.ConfigSource> columnOptions,
org.embulk.spi.BufferAllocator allocator,
org.embulk.spi.PageBuilder pageBuilder,
org.embulk.spi.Schema schema,
org.embulk.spi.PageOutput output) |
static DynamicPageBuilder |
createWithTimestampMetadataFromColumn(String defaultZoneString,
Map<String,org.embulk.config.ConfigSource> columnOptions,
org.embulk.spi.BufferAllocator allocator,
org.embulk.spi.PageBuilder pageBuilder,
org.embulk.spi.Schema schema,
org.embulk.spi.PageOutput output) |
void |
finish() |
void |
flush() |
List<org.embulk.spi.Column> |
getColumns() |
DynamicColumnSetter |
lookupColumn(String columnName) |
public static DynamicPageBuilder createWithTimestampMetadata(String defaultZoneString, Map<String,org.embulk.config.ConfigSource> columnOptions, org.embulk.spi.BufferAllocator allocator, org.embulk.spi.PageBuilder pageBuilder, org.embulk.spi.Schema schema, org.embulk.spi.PageOutput output)
public static DynamicPageBuilder createWithTimestampMetadataFromColumn(String defaultZoneString, Map<String,org.embulk.config.ConfigSource> columnOptions, org.embulk.spi.BufferAllocator allocator, org.embulk.spi.PageBuilder pageBuilder, org.embulk.spi.Schema schema, org.embulk.spi.PageOutput output)
public List<org.embulk.spi.Column> getColumns()
public DynamicColumnSetter column(org.embulk.spi.Column c)
public DynamicColumnSetter column(int index)
public DynamicColumnSetter lookupColumn(String columnName)
public DynamicColumnSetter columnOrSkip(int index)
public DynamicColumnSetter columnOrSkip(String columnName)
protected DynamicColumnSetter columnOrNull(int index)
protected DynamicColumnSetter columnOrNull(String columnName)
public void addRecord()
public void flush()
public void finish()
public void close()
close
in interface AutoCloseable