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, toStringpublic 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