public interface Table
Modifier and Type | Interface and Description |
---|---|
static class |
Table.TableGroup
ENUM for table groups.
|
static class |
Table.TableStatus |
Modifier and Type | Method and Description |
---|---|
Timestamp |
getCreateTime()
Returns the time when the table was created
|
String |
getDescription()
A description of the table
|
List<Schema.Field> |
getFields()
Returns the fields describing the table columns.
|
List<Schema.Field> |
getFields(boolean includeInternal)
Returns the fields describing the table columns.
|
String |
getFilter()
Returns the filter on the base table
|
String |
getGroup()
A table can be assigned to a logical group.
|
List<List<String>> |
getIndices()
Returns all the indices for the table.
|
List<Schema.Field> |
getKeyFields()
Returns the schema which describes the key for the records in this table.
|
String |
getKeyFieldsCsv()
Returns the key fields table in the form of CSV.
|
String |
getName()
The name of the table.
|
EnumSet<LiveViewQueryLanguage> |
getQueryLanguages()
Returns the languages that can be used for queries against this table.
|
String |
getShortDescription()
A short description of the table
|
EnumSet<LiveViewTableCapability> |
getTableCapabilities()
Returns the capabilities that this Table supports.
|
TablePublisher |
getTablePublisher(String publisherName)
Retrieve a publisher instance allowing a client to publish data to this table with the default buffer size
TablePublisher.PUBLISH_BUFFER_SIZE_DEFAULT and
flush interval TablePublisher.PUBLISH_INTERVAL_DEFAULT . |
TablePublisher |
getTablePublisher(String publisherName,
int bufferSize,
long flushInterval,
TimeUnit flushIntervalTimeUnit)
Retrieve a
TablePublisher instance allowing the client to publish data to the table. |
TablePublisher |
getTablePublisher(String publisherName,
int bufferSize,
long flushInterval,
TimeUnit flushIntervalUnit,
PublisherListener pubListener,
PubListenerConfig pubListenerConfig)
Retrieve a
TablePublisher publisher instance allowing the client to publish data to the table. |
TablePublisher |
getTablePublisher(String publisherName,
PublisherListener pubListener,
PubListenerConfig pubListenerConfig)
Retrieve a
TablePublisher instance allowing a client to publish data to this table with the default buffer size TablePublisher.PUBLISH_BUFFER_SIZE_DEFAULT and
flush interval TablePublisher.PUBLISH_INTERVAL_DEFAULT . |
String |
getTableSpaceRef()
Returns the table space reference for the given table.
|
Table.TableStatus |
getTableStatus()
Get the status of the table.
|
String |
getTableStatusMessage()
Returns the table status message.
|
Collection<String> |
getUnmetClientCapabilities()
Every table might have requiredClientCapabilities which may not be supported
by the current client.
|
boolean |
isEnabled()
Sometimes Tables will be disabled, because the Container that they are in has been shut down.
|
boolean |
isSystemTable()
Returns true if the table is a system table.
|
static final String LV_STATS_TABLE
static final String LV_ALERTS_TABLE
static final String TABLES_TABLE_NAME
static final String NAME_FIELD
static final String GROUP_FIELD
static final String TABLE_SPACE_FIELD
static final String DESCRIPTION_FIELD
static final String SHORT_DESCRIPTION_FIELD
static final String QUERY_LANGUAGES_FIELD
static final String CAPABILITIES_FIELD
static final String IS_ENABLED_FIELD
static final String FIELDLIST_FIELD
static final String TABLE_SCHEMA_FIELD
static final String KEY_FIELDS_CSV
static final String REQUIRED_CLIENT_CAPABILITIES
static final String INDICES_FIELD
static final String STATUS_FIELD
static final String STATUS_MESSAGE_FIELD
static final String IS_SYSTEM_TABLE
static final String CREATE_TIME
static final String FILTER
static final String NUM_SERVERS
static final String REJECTED_SERVERS
static final String SM_DISCOVERD_AT_START
static final String SM_REMOVING
static final String SM_DEFINED
static final String SM_LOADING
static final String SM_TABLE_CONTAINER_MISSING
static final String SM_DYANAMICALLY_ADDED
static final String SM_FILTERED_TABLE_DISCOVERED_AT_START_TIME
static final String SM_FILTERED_TABLE_ERROR_PREDICATE_VALIDATION
static final String SM_FILTERED_TABLE_DYNAMICALLY_ADDED
static final String SYS_TABLES_GROUP
static final String CEP_TABLES_GROUP
static final EnumSet<LiveViewQueryLanguage> LIVEVIEW_LANGUAGE_ONLY
static final EnumSet<LiveViewTableCapability> REAL_LV_CAPABILITIES
static final EnumSet<LiveViewTableCapability> CAPABILITIES_FOR_FILTERED_TABLES
String getName()
String getGroup()
String getShortDescription()
String getDescription()
List<Schema.Field> getFields()
List<Schema.Field> getFields(boolean includeInternal)
includeInternal
- specifies whether to include system internal fields in the listList<Schema.Field> getKeyFields()
EnumSet<LiveViewQueryLanguage> getQueryLanguages()
LiveViewQueryLanguage
EnumSet<LiveViewTableCapability> getTableCapabilities()
LiveViewTableCapability
TablePublisher getTablePublisher(String publisherName)
TablePublisher.PUBLISH_BUFFER_SIZE_DEFAULT
and
flush interval TablePublisher.PUBLISH_INTERVAL_DEFAULT
.publisherName
- assigns a name to the publisher. Data published will include the publisher
name for tracking and recoverability purposes.TablePublisher getTablePublisher(String publisherName, PublisherListener pubListener, PubListenerConfig pubListenerConfig) throws LiveViewException
TablePublisher
instance allowing a client to publish data to this table with the default buffer size TablePublisher.PUBLISH_BUFFER_SIZE_DEFAULT
and
flush interval TablePublisher.PUBLISH_INTERVAL_DEFAULT
.publisherName
- assigns a name to the publisher. Data published will include the publisher
name for tracking and recoverability purposes.pubListener
- The PublisherListener
on which the acknowledgement for the published tuples should be received.TablePublisher
implementation.LiveViewException
TablePublisher getTablePublisher(String publisherName, int bufferSize, long flushInterval, TimeUnit flushIntervalTimeUnit)
TablePublisher
instance allowing the client to publish data to the table.publisherName
- assigns a name to the publisher. Data published will include the publisher
name for tracking and recoverability purposes.bufferSize
- number of tuples to buffer client side before sending to server. A higher number
produces better throughput but higher latency. Ignored for LowLatencyPublisherflushInterval
- The interval between flushing the buffered tuples if the buffer does not completely fill. If a flushInterval
of less than or equal to zero specified, a low latency TablePublisher implementation will be used to sends data to the server
on the client's thread. Note the LowLatencyPublisher ignores bufferSize.flushIntervalTimeUnit
- The time unit of the flush intervalTablePublisher
implementation.TablePublisher getTablePublisher(String publisherName, int bufferSize, long flushInterval, TimeUnit flushIntervalUnit, PublisherListener pubListener, PubListenerConfig pubListenerConfig) throws LiveViewException
TablePublisher
publisher instance allowing the client to publish data to the table.publisherName
- assigns a name to the publisher. Data published will include the publisher
name for tracking and recoverability purposes.bufferSize
- number of tuples to buffer client side before sending to server. A higher number
produces better throughput but higher latency. Ignored for LowLatencyPublisherflushInterval
- The interval between flushing the buffered tuples if the buffer does not completely fill. If a flushInterval
of less than or equal to zero specified, a low latency TablePublisher implementation will be used to sends data to the server
on the client's thread. Note the LowLatencyPublisher ignores bufferSize.flushIntervalTimeUnit
- The time unit of the flush interval.pubListener
- The PublisherListener
on which the acknowledgement for the published tuples should be received.TablePublisher
implementation.LiveViewException
boolean isEnabled()
Table.TableStatus getTableStatus()
TableAdminManager
this tells you where it is in the loading process.Table.TableStatus
Collection<String> getUnmetClientCapabilities()
String
representing the capabilities that
are not met by the client.List<List<String>> getIndices()
String getTableSpaceRef()
String getKeyFieldsCsv()
String getTableStatusMessage()
boolean isSystemTable()
Timestamp getCreateTime()
String getFilter()
Copyright © 2015–2019 Cloud Software Group, Inc.. All rights reserved.