Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_FIELD_NAME_MAPPING_SPLIT_TOKEN |
":" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HSQLDBSERVER_PROFILE |
"hsqldbServer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONTAINER_ID_KEY |
"id" |
public static final java.lang.String |
GROUPS_KEY |
"groups" |
public static final java.lang.String |
HOST_KEY |
"host" |
public static final java.lang.String |
IP_ADDRESS_KEY |
"ip" |
public static final java.lang.String |
MGMT_PORT_KEY |
"managementPort" |
public static final java.lang.String |
PROCESS_ID_KEY |
"pid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONSUMER |
"consumer" |
public static final java.lang.String |
DIRECT |
"direct" |
public static final java.lang.String |
PRODUCER |
"producer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BACK_OFF_INITIAL_INTERVAL |
"backOffInitialInterval" |
public static final java.lang.String |
BACK_OFF_MAX_INTERVAL |
"backOffMaxInterval" |
public static final java.lang.String |
BACK_OFF_MULTIPLIER |
"backOffMultiplier" |
public static final java.lang.String |
CONCURRENCY |
"concurrency" |
public static final java.lang.String |
DIRECT_BINDING_ALLOWED |
"directBindingAllowed" |
public static final java.lang.String |
MAX_ATTEMPTS |
"maxAttempts" |
public static final java.lang.String |
MAX_CONCURRENCY |
"maxConcurrency" |
public static final java.lang.String |
PARTITION_COUNT |
"partitionCount" |
public static final java.lang.String |
PARTITION_INDEX |
"partitionIndex" |
public static final java.lang.String |
PARTITION_KEY_EXPRESSION |
"partitionKeyExpression" |
public static final java.lang.String |
PARTITION_KEY_EXTRACTOR_CLASS |
"partitionKeyExtractorClass" |
public static final java.lang.String |
PARTITION_SELECTOR_CLASS |
"partitionSelectorClass" |
public static final java.lang.String |
PARTITION_SELECTOR_EXPRESSION |
"partitionSelectorExpression" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
JOB_CHANNEL_TYPE_PREFIX |
"job:" |
protected static final java.lang.String |
ORIGINAL_CONTENT_TYPE_HEADER |
"originalContentType" |
protected static final java.lang.String |
P2P_NAMED_CHANNEL_TYPE_PREFIX |
"queue:" |
protected static final java.lang.String |
PARTITION_HEADER |
"partition" |
protected static final java.lang.String |
PUBSUB_NAMED_CHANNEL_TYPE_PREFIX |
"topic:" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
JOB_CHANNEL_PREFIX |
"job:" |
protected static final java.lang.String |
MODULE_INPUT_CHANNEL |
"input" |
protected static final java.lang.String |
MODULE_OUTPUT_CHANNEL |
"output" |
protected static final java.lang.String |
TAP_CHANNEL_PREFIX |
"tap:" |
protected static final java.lang.String |
TOPIC_CHANNEL_PREFIX |
"topic:" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
PLUGIN_CONTEXT_CONFIG_ROOT |
"META-INF/spring-xd/plugins/" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BATCH_EXCEPTION |
"xd_batch_exception" |
public static final java.lang.String |
BATCH_LISTENER_EVENT_TYPE |
"xd_batch_listener_event_type" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ABSOLUTE_FILE_PATH |
"absoluteFilePath" |
public static final java.lang.String |
IS_RESTART_JOB_PARAMETER_KEY |
"XD_isRestart" |
public static final java.lang.String |
UNIQUE_JOB_PARAMETER_KEY |
"random" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JOB_PARAMETERS_KEY |
"jobParameters" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CHUNK_EVENTS_SUFFIX |
"chunk" |
public static final java.lang.String |
ITEM_EVENTS_SUFFIX |
"item" |
public static final java.lang.String |
JOB_EXECUTION_EVENTS_SUFFIX |
"job" |
public static final java.lang.String |
SKIP_EVENTS_SUFFIX |
"skip" |
public static final java.lang.String |
STEP_EXECUTION_EVENTS_SUFFIX |
"step" |
public static final java.lang.String |
XD_AGGREGATED_EVENTS_CHANNEL |
"xd.job.aggregatedEvents" |
public static final java.lang.String |
XD_CHUNK_EVENTS_CHANNEL |
"xd.job.chunkEvents" |
public static final java.lang.String |
XD_CHUNK_LISTENER_BEAN |
"xd.chunkListener" |
public static final java.lang.String |
XD_ITEM_EVENTS_CHANNEL |
"xd.job.itemEvents" |
public static final java.lang.String |
XD_ITEM_LISTENER_BEAN |
"xd.itemListener" |
public static final java.lang.String |
XD_JOB_EXECUTION_EVENTS_CHANNEL |
"xd.job.jobExecutionEvents" |
public static final java.lang.String |
XD_JOB_EXECUTION_LISTENER_BEAN |
"xd.jobExecutionListener" |
public static final java.lang.String |
XD_SKIP_EVENTS_CHANNEL |
"xd.job.skipEvents" |
public static final java.lang.String |
XD_SKIP_LISTENER_BEAN |
"xd.skipListener" |
public static final java.lang.String |
XD_STEP_EXECUTION_EVENTS_CHANNEL |
"xd.job.stepExecutionEvents" |
public static final java.lang.String |
XD_STEP_EXECUTION_LISTENER_BEAN |
"xd.stepExecutionListener" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
EMBEDDED_ZK_CONNECT |
"zk.embedded.client.connect" |
public static final java.lang.String |
ZK_CONNECT |
"zk.client.connect" |
public static final java.lang.String |
ZK_PROPERTIES_SOURCE |
"zk-properties" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
QUEUE_PREFIX |
"queue:" |
protected static final java.lang.String |
TOPIC_PREFIX |
"topic:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_ADMIN_UI_BASE_PATH |
"admin-ui" |
public static final java.lang.String |
XD_BATCH_CONFIG_ROOT |
"META-INF/spring-xd/batch/" |
public static final java.lang.String |
XD_CONFIG_ROOT |
"META-INF/spring-xd/" |
public static final java.lang.String |
XD_INTERNAL_CONFIG_ROOT |
"META-INF/spring-xd/internal/" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADMIN_PROFILE |
"admin" |
public static final java.lang.String |
CONTAINER_PROFILE |
"container" |
public static final java.lang.String |
SINGLENODE_PROFILE |
"singlenode" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADMINS |
"admins" |
public static final java.lang.String |
ALLOCATED |
"allocated" |
public static final java.lang.String |
CONTAINERS |
"containers" |
public static final java.lang.String |
DEPLOYMENTS |
"deployments" |
public static final java.lang.String |
JOB_DEPLOYMENTS |
"deployments/jobs" |
public static final java.lang.String |
JOBS |
"jobs" |
public static final java.lang.String |
METADATA |
"metadata" |
public static final java.lang.String |
MODULE_DEPLOYMENTS |
"deployments/modules" |
public static final java.lang.String |
MODULES |
"modules" |
public static final java.lang.String |
REQUESTED |
"requested" |
public static final java.lang.String |
STATUS |
"status" |
public static final java.lang.String |
STREAM_DEPLOYMENTS |
"deployments/streams" |
public static final java.lang.String |
STREAMS |
"streams" |
public static final java.lang.String |
TAPS |
"taps" |
public static final java.lang.String |
XD_NAMESPACE |
"xd" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_CLIENT_CONNECT_STRING |
"localhost:2181" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_BASE_FILENAME |
"data" |
public static final java.lang.String |
DEFAULT_BASE_PATH |
"/data/" |
public static final java.lang.String |
DEFAULT_FILE_SUFFIX |
"log" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DATA_PATH |
"/xd" |
public static final java.lang.String |
DEFAULT_ID_FILE_NAMING_STRATEGY |
"fileNamingStrategy" |
public static final java.lang.String |
DEFAULT_ID_FILE_ROLLOVER_STRATEGY |
"fileRolloverStrategy" |
public static final java.lang.String |
DEFAULT_ID_STORE_WRITER |
"storeWriter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
REACTOR_ENV_BEAN_NAME |
"reactorEnv" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADMIN_TOKEN |
"adminNode" |
public static final java.lang.String |
CONTAINER_TOKEN |
"containerNode" |
public static final java.lang.String |
SINGLENODE_TOKEN |
"singleNode" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TMP_DIR |
"result/" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HTTP_PREFIX |
"http://" |
public static final java.lang.String |
RESULT_LOCATION |
"/tmp/xd/output" |
public static final java.lang.String |
XD_ADMIN_HOST |
"xd_admin_host" |
public static final java.lang.String |
XD_HTTP_PORT |
"xd_http_port" |
public static final java.lang.String |
XD_JMX_PORT |
"xd_jmx_port" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COUNT_KEY |
"count" |
public static final java.lang.String |
CRITERIA_KEY |
"criteria" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SEQUENCE_KEY |
"sequence" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
OPTION_SEPARATOR |
"." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
OPTIONS_CLASS |
"options_class" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
NO_DEFAULT |
"__NULL__" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_CONTAINER_KEY_PREFIX |
"xd.container." |
public static final java.lang.String |
XD_JOB_NAME |
"${xd.job.name}" |
public static final java.lang.String |
XD_JOB_NAME_KEY |
"xd.job.name" |
public static final java.lang.String |
XD_MODULE_INDEX |
"${xd.module.index}" |
public static final java.lang.String |
XD_MODULE_INDEX_KEY |
"xd.module.index" |
public static final java.lang.String |
XD_MODULE_LABEL |
"${xd.module.label}" |
public static final java.lang.String |
XD_MODULE_LABEL_KEY |
"xd.module.label" |
public static final java.lang.String |
XD_MODULE_NAME |
"${xd.module.name}" |
public static final java.lang.String |
XD_MODULE_NAME_KEY |
"xd.module.name" |
public static final java.lang.String |
XD_MODULE_TYPE |
"${xd.module.type}" |
public static final java.lang.String |
XD_MODULE_TYPE_KEY |
"xd.module.type" |
public static final java.lang.String |
XD_STREAM_NAME |
"${xd.stream.name}" |
public static final java.lang.String |
XD_STREAM_NAME_KEY |
"xd.stream.name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_XD_DATE_FORMAT_PATTERN |
"yyyy-MM-dd" |
public static final java.lang.String |
DEFAULT_XD_DATE_TIME_FORMAT_PATTERN |
"yyyy-MM-dd HH:mm:ss,SSS" |
public static final java.lang.String |
DEFAULT_XD_DURATION_FORMAT_PATTERN |
"HH:mm:ss" |
public static final java.lang.String |
DEFAULT_XD_TIME_FORMAT_PATTERN |
"HH:mm:ss" |
public static final java.lang.String |
DEFAULT_XD_TIMEZONE_ID |
"UTC" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST |
"localhost" |
public static final java.lang.String |
DEFAULT_PASSWORD |
"" |
public static final int |
DEFAULT_PORT |
9393 |
public static final java.lang.String |
DEFAULT_SCHEME |
"http" |
public static final java.lang.String |
DEFAULT_TARGET |
"http://localhost:9393/" |
public static final java.lang.String |
DEFAULT_USERNAME |
"" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT |
"<use platform locale>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
NOT_AVAILABLE |
"N/A" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COLUMN_1 |
1 |
public static final int |
COLUMN_2 |
2 |
public static final int |
COLUMN_3 |
3 |
public static final int |
COLUMN_4 |
4 |
public static final int |
COLUMN_5 |
5 |
public static final int |
COLUMN_6 |
6 |
public static final java.lang.String |
HORIZONTAL_LINE |
"-------------------------------------------------------------------------------\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_EXTERNAL_SERVERS_REQUIRED |
"XD_EXTERNAL_SERVERS_REQUIRED" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
ADMIN_PASSWORD |
"secret" |
protected static final java.lang.String |
ADMIN_USER |
"johndoe" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"filejdbctest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"filejdbctest.out" |
public static final java.lang.String |
DEFAULT_NAMES |
"data" |
public static final java.lang.String |
DEFAULT_TABLE_NAME |
"filejdbctest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/filepollhdfsjob" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"filePollHdfsJob" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST_NAME |
"localhost" |
public static final java.lang.String |
DEFAULT_PORT |
"4444" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/hdfsjdbctest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"hdfsjdbctest" |
public static final java.lang.String |
DEFAULT_NAMES |
"data" |
public static final java.lang.String |
DEFAULT_TABLE_NAME |
"hdfsjdbctest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_COLLECTION_NAME |
"hdfsmongodbtest" |
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/hdfsmongodbtest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"hdfsmongodbtest" |
public static final java.lang.String |
DEFAULT_ID_FIELD |
"data" |
public static final java.lang.String |
DEFAULT_NAMES |
"data" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/acceptancetest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"ACCTEST" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/jdbchdfstest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"jdbchdfstest.out" |
public static final java.lang.String |
DEFAULT_SQL |
"select payload from jdbchdfstest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_PORT |
61616 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_ADDRESSES |
"localhost:5672" |
public static final java.lang.String |
DEFAULT_EXCHANGE |
"RabbitSource" |
public static final java.lang.String |
DEFAULT_ROUTING_KEY |
"rabbitfixture.rabbit_sink" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_EXCHANGE |
"RabbitSource" |
public static final java.lang.String |
DEFAULT_QUEUE |
"rabbit_source" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_MODE |
"REPLACE" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST |
"localhost" |
public static final int |
DEFAULT_PORT |
5140 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST |
"localhost" |
public static final int |
DEFAULT_PORT |
5140 |