Page History

...

• source: The name of the access operator. Remark: This name must be different to all source names and all view or stream definitions! A new source will be added to the data dictionary automatically.
• wrapper: In Odysseus the default wrappers are GenericPush and GenericPull
• transport: The transport defines the transport protocol to use.
• protocol: The protocol parameter defines the application protocol to transform the processing results.

• datahandler: This parameter defines the transform of the single attributes of the processing results.
• options: Transport protocol and application protocol depending options
• schema: The output schema of the access operator (may depend on the protocol handler)
• metaattribute: What kind of meta data should the source provide.
• readMetaData: If you receiving data that already contains meta data in an Odysseus based format (e.g. if you are sending from another Odysseus node) this value must be set to 'true' (default is false), to read this meta data. Important: In this case, the schema should not contain Timestamp attributes, else the meta data may be overwritten.

There are some options that are not used by transformation:

• BaseTimeUnit: Timeunit used for long based input start/endtimestamps (be careful, the option is case sensitive). The TimeUnits are case sensitive as well, e.g. SECONDS (https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html)

Example

PQL

input = ACCESS({source='Source',
wrapper='GenericPush',
transport='TCPClient',
protocol='CSV',
dataHandler='Tuple',
METAATTRIBUTE = ['TimeInterval','Latency','Datarate'], /// or: METAATTRIBUTE = 'TimeIntervalLatencyDatarate'
options=[['host', 'example.com'],['port', '8080'],['read', '10240'],['write', '10240']],
schema=[
['id', 'Double'],
['data', 'String']]
})
 

There are some special logical Operators, that allow an easier handling of the ACCESS-Operation (but are semantically equal)