public static final java.lang.String |
AUTH_KEYTAB |
"AUTH_KEYTAB" |
public static final java.lang.String |
AUTH_METASTORE_PRINCIPAL |
"AUTH_METASTORE_PRINCIPAL" |
public static final java.lang.String |
AUTH_METHOD |
"AUTH_METHOD" |
public static final java.lang.String |
AUTH_USERNAME |
"AUTH_USERNAME" |
public static final java.lang.String |
COLUMN_MAPPING_KEY |
"COLUMN_MAPPING" |
public static final java.lang.String |
COLUMN_QUOTE_CHARACTER |
"QUOTE_CHARACTER" |
public static final java.lang.String |
CONFIG_PATH |
"CONFIG_PATH" |
public static final java.lang.String |
DEFAULT_PARSER_QUEUE_SIZE |
"2" |
public static final java.lang.String |
DISALLOW_QUOTED_ROW_SEPARATOR |
"DISALLOW_QUOTED_ROW_SEPARATOR" |
public static final java.lang.String |
DISCARD_ROW_ON_PARSE_ERROR_KEY |
"DISCARD_ROW_ON_PARSE_ERROR" |
public static final java.lang.String |
ECDA_SESSION_NAME |
"ECDA_SESSION_NAME" |
public static final java.lang.String |
FILE_COMPRESSION |
"FILE_COMPRESSION" |
public static final java.lang.String |
FILE_COMPRESSION_BUFFER |
"FILE_COMPRESSION_BUFFER" |
public static final java.lang.String |
FILE_ROTATION_RESPECT_ROWTIME |
"FILE_ROTATION_RESPECT_ROWTIME" |
public static final java.lang.String |
FILE_ROTATION_ROWCOUNT |
"FILE_ROTATION_ROWCOUNT" |
public static final java.lang.String |
FILE_ROTATION_SIZE |
"FILE_ROTATION_SIZE" |
public static final java.lang.String |
FILE_ROTATION_TIME |
"FILE_ROTATION_TIME" |
public static final java.lang.String |
FILE_ROTATION_WATERMARK_COLUMN |
"FILE_ROTATION_WATERMARK_COLUMN" |
public static final java.lang.String |
FILE_TYPE |
"file" |
public static final java.lang.String |
FILENAME_DATE_FORMAT |
"FILENAME_DATE_FORMAT" |
public static final java.lang.String |
FILENAME_PATTERN |
"FILENAME_PATTERN" |
public static final java.lang.String |
FILENAME_PREFIX |
"FILENAME_PREFIX" |
public static final java.lang.String |
FILENAME_SUFFIX |
"FILENAME_SUFFIX" |
public static final java.lang.String |
FORMAT_CHARSET_KEY |
"CHARACTER_ENCODING" |
public static final java.lang.String |
FORMAT_TYPE_KEY |
"FORMAT_TYPE" |
public static final java.lang.String |
FORMAT_WRITE_HEADER_KEY |
"WRITE_HEADER" |
public static final java.lang.String |
FORMATTER_CLASSNAME_KEY |
"FORMATTER_CLASSNAME" |
public static final java.lang.String |
FORMATTER_INCLUDE_ROWTIME |
"FORMATTER_INCLUDE_ROWTIME" |
public static final java.lang.String |
FORMATTER_PREFIX |
"FORMATTER_" |
public static final java.lang.String |
FORMATTER_TYPE |
"FORMATTER" |
public static final java.lang.String |
HDFS_LOG_DIRECTORY |
"com.sqlstream.plugin.hdfs" |
public static final java.lang.String |
HDFS_OUTPUT_DIR |
"HDFS_OUTPUT_DIR" |
public static final java.lang.String |
HDFS_POLLING_INTERVAL |
"HDFS_POLLING_INTERVAL" |
public static final java.lang.String |
HDFS_TYPE |
"hdfs" |
public static final java.lang.String |
HIVE_METASTORE_URIS |
"HIVE_METASTORE_URIS" |
public static final java.lang.String |
HIVE_PARTITION_NAME_FORMAT_SUFFIX |
"_HIVE_PARTITION_NAME_FORMAT" |
public static final java.lang.String |
HIVE_SCHEMA_NAME |
"HIVE_SCHEMA_NAME" |
public static final java.lang.String |
HIVE_SKIP_MSCK |
"HIVE_SKIP_MSCK" |
public static final java.lang.String |
HIVE_TABLE_NAME |
"HIVE_TABLE_NAME" |
public static final java.lang.String |
HIVE_TEMPLATE_SCHEMA_NAME |
"HIVE_TEMPLATE_SCHEMA_NAME" |
public static final java.lang.String |
HIVE_TEMPLATE_TABLE_NAME |
"HIVE_TEMPLATE_TABLE_NAME" |
public static final java.lang.String |
HIVE_TYPE |
"hive" |
public static final java.lang.String |
HIVE_URI |
"HIVE_URI" |
public static final java.lang.String |
INTERNAL_PREFIX |
"SQLSTREAM_INTERNAL" |
public static final java.lang.String |
IS_IPV6_KEY |
"IS_IPV6" |
public static final java.lang.String |
IS_TCP_KEY |
"IS_TCP" |
public static final java.lang.String |
JDBC_TYPE |
"sys_jdbc" |
public static final java.lang.String |
KERBEROS_SECURITY |
"kerberos" |
public static final java.lang.String |
MAX_PUNCT_TIME |
"MAX_PUNCT_TIME" |
public static final java.lang.String |
MESSAGE_STREAM |
"MESSAGE_STREAM" |
public static final java.lang.String |
MIN_PUNCT_TIME |
"MIN_PUNCT_TIME" |
public static final java.lang.String |
OPTIONS_QUERY |
"OPTIONS_QUERY" |
public static final java.lang.String |
ORC_BATCH_SIZE |
"orc.batch.size" |
public static final java.lang.String |
ORC_BLOCK_PADDING |
"orc.block.padding" |
public static final java.lang.String |
ORC_BLOCK_SIZE |
"orc.block.size" |
public static final java.lang.String |
ORC_BLOOM_FILTER_COLUMNS |
"orc.bloom.filter.columns" |
public static final java.lang.String |
ORC_BLOOM_FILTER_FPP |
"orc.bloom.filter.fpp" |
public static final java.lang.String |
ORC_COMPRESS |
"orc.compress" |
public static final java.lang.String |
ORC_COMPRESS_SIZE |
"orc.compress.size" |
public static final java.lang.String |
ORC_DIRECT_ENCODING_COLUMNS |
"orc.direct.encoding.columns" |
public static final java.lang.String |
ORC_OPTION_PREFIX |
"orc." |
public static final java.lang.String |
ORC_ROW_INDEX_STRIDE |
"orc.row.index.stride" |
public static final java.lang.String |
ORC_SORT_ORDER |
"ORC_SORT_ORDER" |
public static final java.lang.String |
ORC_STRIPE_SIZE |
"orc.stripe.size" |
public static final java.lang.String |
ORC_USER_METADATA_PREFIX |
"orc.user.metadata_" |
public static final java.lang.String |
ORC_VERSION |
"orc.version" |
public static final java.lang.String |
ORIGINAL_FILENAME |
"ORIGINAL_FILENAME" |
public static final java.lang.String |
PARSER_CHARSET_KEY |
"CHARACTER_ENCODING" |
public static final java.lang.String |
PARSER_PREFIX |
"PARSER_" |
public static final java.lang.String |
PARSER_QUEUE_SIZE |
"PARSER_QUEUE_SIZE" |
public static final java.lang.String |
PARSER_SKIP_HEADER_KEY |
"SKIP_HEADER" |
public static final java.lang.String |
PARSER_TYPE |
"PARSER" |
public static final java.lang.String |
PATH_SUFFIX |
"_PATH" |
public static final java.lang.String |
PLUGIN_LEVEL |
"plugin" |
public static final java.lang.String |
POSTPROCESS_COMMAND |
"POSTPROCESS_COMMAND" |
public static final java.lang.String |
PROJECTED_COLUMN_MAPPING_KEY |
"_PROJECTED_COLUMN_MAPPING" |
public static final java.lang.String |
PROV_AMQP_CREATION_TIME |
"SQLSTREAM_PROV_AMQP_CREATION_TIME" |
public static final java.lang.String |
PROV_AMQP_PARTITION |
"SQLSTREAM_PROV_AMQP_PARTITION" |
public static final java.lang.String |
PROV_FILE_SOURCE_FILE |
"SQLSTREAM_PROV_FILE_SOURCE_FILE" |
public static final java.lang.String |
PROV_IBMMQ_APPLICATION_ID_DATA |
"SQLSTREAM_PROV_IBMMQ_APPLICATION_ID_DATA" |
public static final java.lang.String |
PROV_IBMMQ_APPLICATION_ORIGIN_DATA |
"SQLSTREAM_PROV_IBMMQ_APPLICATION_ORIGIN_DATA" |
public static final java.lang.String |
PROV_IBMMQ_GROUP_ID |
"SQLSTREAM_PROV_IBMMQ_GROUP_ID" |
public static final java.lang.String |
PROV_IBMMQ_MESSAGE_SEQUENCE_NUMBER |
"SQLSTREAM_PROV_IBMMQ_MESSAGE_SEQUENCE_NUMBER" |
public static final java.lang.String |
PROV_IBMMQ_PUT_APPLICATION_NAME |
"SQLSTREAM_PROV_IBMMQ_PUT_APPLICATION_NAME" |
public static final java.lang.String |
PROV_IBMMQ_PUT_APPLICATION_TYPE |
"SQLSTREAM_PROV_IBMMQ_PUT_APPLICATION_TYPE" |
public static final java.lang.String |
PROV_IBMMQ_PUT_DATA_TIME |
"SQLSTREAM_PROV_IBMMQ_PUT_DATA_TIME" |
public static final java.lang.String |
PROV_IBMMQ_USER_ID |
"SQLSTREAM_PROV_IBMMQ_USER_ID" |
public static final java.lang.String |
PROV_KAFKA_HEADERS |
"SQLSTREAM_PROV_KAFKA_HEADERS" |
public static final java.lang.String |
PROV_KAFKA_KEY |
"SQLSTREAM_PROV_KAFKA_KEY" |
public static final java.lang.String |
PROV_KAFKA_OFFSET |
"SQLSTREAM_PROV_KAFKA_OFFSET" |
public static final java.lang.String |
PROV_KAFKA_PARTITION |
"SQLSTREAM_PROV_KAFKA_PARTITION" |
public static final java.lang.String |
PROV_KAFKA_PAYLOAD_PREFIX |
"SQLSTREAM_PROV_KAFKA_PAYLOAD_PREFIX" |
public static final java.lang.String |
PROV_KAFKA_TIMESTAMP |
"SQLSTREAM_PROV_KAFKA_TIMESTAMP" |
public static final java.lang.String |
PROV_KAFKA_TOPIC |
"SQLSTREAM_PROV_KAFKA_TOPIC" |
public static final java.lang.String |
PROV_KINESIS_PARTITION_ID |
"SQLSTREAM_PROV_KINESIS_PARTITION_ID" |
public static final java.lang.String |
PROV_KINESIS_SEQUENCE_NUMBER |
"SQLSTREAM_PROV_KINESIS_SEQUENCE_NUMBER" |
public static final java.lang.String |
PROV_KINESIS_SHARD_ID |
"SQLSTREAM_PROV_KINESIS_SHARD_ID" |
public static final java.lang.String |
PROV_MQTT_MESSAGE_ID |
"SQLSTREAM_PROV_MQTT_MESSAGE_ID" |
public static final java.lang.String |
PROV_MQTT_TOPIC |
"SQLSTREAM_PROV_MQTT_TOPIC" |
public static final java.lang.String |
PROV_PARSE_ERROR |
"SQLSTREAM_PROV_PARSE_ERROR" |
public static final java.lang.String |
PROV_PARSE_LINE_NUMBER |
"SQLSTREAM_PROV_TEXT_PARSE_LINE_NUMBER" |
public static final java.lang.String |
PROV_PARSE_POSITION |
"SQLSTREAM_PROV_PARSE_POSITION" |
public static final java.lang.String |
PROV_ROW_PAYLOAD |
"SQLSTREAM_PROV_ROW_PAYLOAD" |
public static final java.lang.String |
PROV_SOCKET_SOURCE_HOST |
"SQLSTREAM_PROV_SOCKET_SOURCE_HOST" |
public static final java.lang.String |
PROV_SOCKET_SOURCE_PORT |
"SQLSTREAM_PROV_SOCKET_SOURCE_PORT" |
public static final java.lang.String |
PROVENANCE_PREFIX |
"SQLSTREAM_PROV" |
public static final java.lang.String |
QUOTED_COLUMNS |
"QUOTED_COLUMNS" |
public static final java.lang.String |
RELATION_NAME |
"SQLSTREAM_INTERNAL_RELATION_NAME" |
public static final java.lang.String |
REMOTE_HOST_KEY |
"REMOTE_HOST" |
public static final java.lang.String |
REMOTE_PORT_KEY |
"REMOTE_PORT" |
public static final java.lang.String |
REPEAT |
"REPEAT" |
public static final java.lang.String |
ROOT_DIRECTORY |
"DIRECTORY" |
public static final java.lang.String |
ROW_SEPARATOR_CHAR_KEY |
"ROW_SEPARATOR" |
public static final java.lang.String |
ROWTIME_COLUMN_NAME |
"ROWTIME" |
public static final java.lang.String |
SEPARATOR_CHAR_KEY |
"SEPARATOR" |
public static final java.lang.String |
SERVER_HOST_KEY |
"SERVER_HOST" |
public static final java.lang.String |
SERVER_PORT_KEY |
"SERVER_PORT" |
public static final java.lang.String |
SERVER_TYPE |
"TYPE" |
public static final java.lang.String |
SORT_BY_TIMESTAMP |
"SORT_BY_TIMESTAMP" |
public static final java.lang.String |
SQLSTREAM_PREFIX |
"SQLSTREAM" |
public static final java.lang.String |
STARTING_OUTPUT_ROWTIME |
"STARTING_OUTPUT_ROWTIME" |
public static final java.lang.String |
STARTING_POSITION |
"STARTING_POSITION" |
public static final java.lang.String |
STARTING_TIME |
"STARTING_TIME" |
public static final java.lang.String |
STATIC_FILES |
"STATIC_FILES" |
public static final java.lang.String |
TOY_HASH_BUCKETS |
"TOY_HASH_BUCKETS" |
public static final java.lang.String |
TOY_HASH_COLUMNS |
"TOY_HASH_COLUMNS" |
public static final java.lang.String |
TOY_PARTITION_COLUMNS |
"TOY_PARTITION_COLUMNS" |
public static final java.lang.String |
TOY_VERBOSE |
"TOY_VERBOSE" |
public static final java.lang.String |
TYPE_AVRO |
"AVRO" |
public static final java.lang.String |
TYPE_CSV |
"CSV" |
public static final java.lang.String |
TYPE_DISCOVERY |
"DISCOVERY" |
public static final java.lang.String |
TYPE_FAST_REGEX |
"FastRegex" |
public static final java.lang.String |
TYPE_FCLP |
"FCLP" |
public static final java.lang.String |
TYPE_JSON |
"JSON" |
public static final java.lang.String |
TYPE_KEY_VALUE |
"KV" |
public static final java.lang.String |
TYPE_MULTIROW |
"MultiRow" |
public static final java.lang.String |
TYPE_NONE |
"NONE" |
public static final java.lang.String |
TYPE_ORC |
"ORC" |
public static final java.lang.String |
TYPE_PROTOBUF |
"PROTOBUF" |
public static final java.lang.String |
TYPE_TOY |
"toy" |
public static final java.lang.String |
TYPE_VCLP |
"VCLP" |
public static final java.lang.String |
TYPE_W3C |
"W3C" |
public static final java.lang.String |
TYPE_XML |
"XML" |
public static final java.lang.String |
UNKNOWN_TYPE |
"UNKNOWN" |
public static final java.lang.String |
UNPARSED_TEXT_KEY |
"UNPARSED_TEXT" |
public static final java.lang.String |
UNPARSED_TEXT_LAST_COLUMN |
"LAST COLUMN" |
public static final java.lang.String |
UNPARSED_TEXT_NEW_ROW |
"NEW ROW" |
public static final java.lang.String |
UNPARSED_TEXT_TRUNCATE |
"TRUNCATE" |
public static final java.lang.String |
UNPROJECTED_COLUMNS_KEY |
"_UNPROJECTED_COLUMNS_KEY" |
public static final java.lang.String |
UNPROJECTED_NUM_COLUMNS_KEY |
"_UNPROJECTED_NUM_COLUMNS_KEY" |
public static final java.lang.String |
WATERMARK_STORE |
"SQLSTREAM_WATERMARKS" |
public static final java.lang.String |
WATERMARKED_SINK |
"WATERMARKED_SINK" |
public static final java.lang.String |
WATERMARKS |
"WATERMARKS" |
public static final java.lang.String |
WS_POSITION_KEY_COL |
"POSITION_KEY" |
public static final java.lang.String |
WS_SINK_NAME_COL |
"SINK_NAME" |