public class ColumnRiverContext extends SimpleRiverContext
Constructor and Description |
---|
ColumnRiverContext() |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
asMap() |
String |
columnCreatedAt() |
ColumnRiverContext |
columnCreatedAt(String createdAt) |
String |
columnDeletedAt() |
ColumnRiverContext |
columnDeletedAt(String deletedAt) |
boolean |
columnEscape() |
ColumnRiverContext |
columnEscape(boolean escape) |
String |
columnUpdatedAt() |
ColumnRiverContext |
columnUpdatedAt(String updatedAt) |
org.elasticsearch.common.unit.TimeValue |
getLastRunTimeStampOverlap() |
ColumnRiverContext |
setLastRunTimeStampOverlap(org.elasticsearch.common.unit.TimeValue lastRunTimeStampOverlap) |
getAutoCommit, getColumnNameMap, getConnectionProperties, getDefinition, getFetchSize, getLastDatabaseMetadata, getLastEndDate, getLastExecutionEndDate, getLastExecutionStartDate, getLastResultSetMetadata, getLastRow, getLastRowCount, getLastStartDate, getMaxRetryWait, getMaxRows, getMetric, getQueryTimeout, getResultSetConcurrency, getResultSetType, getRetries, getRiverMouth, getRiverSource, getRiverState, getRounding, getScale, getStatements, isTimestampDiffSupported, release, setAutoCommit, setColumnNameMap, setConnectionProperties, setDefinition, setFetchSize, setLastDatabaseMetadata, setLastEndDate, setLastExecutionEndDate, setLastExecutionStartDate, setLastResultSetMetadata, setLastRow, setLastRowCount, setLastStartDate, setMaxRetryWait, setMaxRows, setMetric, setQueryTimeout, setResultSetConcurrency, setResultSetType, setRetries, setRiverMouth, setRiverSource, setRiverState, setRounding, setScale, setStatements, setTimestampDiffSupported, shouldIgnoreNull, shouldIgnoreNull, shouldPrepareDatabaseMetadata, shouldPrepareDatabaseMetadata, shouldPrepareResultSetMetadata, shouldPrepareResultSetMetadata, shouldTreatBinaryAsString, shouldTreatBinaryAsString, toString
public ColumnRiverContext()
public ColumnRiverContext columnUpdatedAt(String updatedAt)
public String columnUpdatedAt()
public ColumnRiverContext columnCreatedAt(String createdAt)
public String columnCreatedAt()
public ColumnRiverContext columnDeletedAt(String deletedAt)
public String columnDeletedAt()
public ColumnRiverContext columnEscape(boolean escape)
public boolean columnEscape()
public org.elasticsearch.common.unit.TimeValue getLastRunTimeStampOverlap()
public ColumnRiverContext setLastRunTimeStampOverlap(org.elasticsearch.common.unit.TimeValue lastRunTimeStampOverlap)
elasticsearch-river-jdbc