public interface IReservedFields
These fields can be generated by entry spouts or by the punch bolt. They are transported on user streams or
on the reserved stream (refer to IReservedStreams
).
Each has a reserved semantics.
Modifier and Type | Field and Description |
---|---|
static String |
_PPF_BATCH_PLAY_ID
Each batch receives a transient unique runtime identifier.
|
static String |
_PPF_BATCH_SIZE
When a batch is completed, the actual number of elements contained in that batch is
part of the end of batch tuple.
|
static String |
_PPF_BATCHID
The persisted batch id is a monotonically increasing counter,
that will be replayed in case a topology is restarted before a batch was fully processed and acknowledged.
|
static String |
_PPF_BYTES_CNT
Indicate the bytes size extracted from archive
|
static String |
_PPF_CHANNEL
This field contains the channel identifier.
|
static String |
_PPF_COMPONENT
This field contains the storm component identifier.
|
static String |
_PPF_ERROR
Deprecated.
|
static String |
_PPF_ERROR_DOCUMENT
This field contains the input document that caused an punch bolt exception.
|
static String |
_PPF_ERROR_MESSAGE
This field contains the error message generated by the punch bolt, if any.
|
static String |
_PPF_ID
This field contains a unique identifier generated by an entry spout.
|
static String |
_PPF_KAFKA_TIMESTAMP
Indicate the timestamp of the kafka record
|
static String |
_PPF_LATENCY
This field contains a json string holding a metric latency record.
|
static String |
_PPF_LINES_CNT
Indicate the line count extracted from archive
|
static String |
_PPF_LOCAL_HOST
This field contains an entry spout listening (udp or tcp) ip address in dotted number format.
|
static String |
_PPF_LOCAL_PORT
This field contains an entry spout listening (udp or tcp) port number.
|
static String |
_PPF_METADATA
Indicate the metadata of the line extracted from archive
|
static String |
_PPF_PARTITION_ID
Indicate the corresponding Kafka partition identifier.
|
static String |
_PPF_PARTITION_OFFSET
Indicate the current Kafka partition offset.
|
static String |
_PPF_PLATFORM
This field contains the platform identifier.
|
static String |
_PPF_REMOTE_HOST
This field contains an entry spout remote source (udp or tcp) ip address in dotted number format.
|
static String |
_PPF_REMOTE_PORT
This field contains an entry spout remote source (udp or tcp) port number.
|
static String |
_PPF_TENANT
This field contains the tenant identifier.
|
static String |
_PPF_TIMESTAMP
This field contains a timestamp in unix miliseconds format.
|
static String |
_PPF_TOPIC_NAME
Indicate the current Kafka topic name
|
static String |
_PPF_TOPOLOGY
This field contains the storm topology identifier.
|
static List<String> |
ALL
List of all existing IReservedFields
|
static String |
PREFIX
Define the prefix used in any IReservedFields
|
static final String PREFIX
static final String _PPF_LATENCY
IReservedStreams#_PPF_METRICS
stream.static final String _PPF_PLATFORM
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_TENANT
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_CHANNEL
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_COMPONENT
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_TOPOLOGY
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_ERROR_DOCUMENT
It is emitted on the IReservedStreams#_PPF_ERRORS
stream.
static final String _PPF_ERROR_MESSAGE
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_TIMESTAMP
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_ID
IReservedStreams#_PPF_ERRORS
stream.static final String _PPF_LOCAL_PORT
static final String _PPF_LOCAL_HOST
static final String _PPF_REMOTE_PORT
static final String _PPF_REMOTE_HOST
It represents the sender source ip address. It is emitted on user streams.
@Deprecated static final String _PPF_ERROR
static final String _PPF_BATCHID
This field is part of both the user tuples and the end-of-batch marker tuple.
static final String _PPF_BATCH_PLAY_ID
static final String _PPF_BATCH_SIZE
static final String _PPF_PARTITION_ID
static final String _PPF_PARTITION_OFFSET
static final String _PPF_TOPIC_NAME
static final String _PPF_KAFKA_TIMESTAMP
static final String _PPF_LINES_CNT
static final String _PPF_BYTES_CNT
static final String _PPF_METADATA
Copyright © 2014–2023. All rights reserved.