public class TelemetrySinkModule extends Object implements SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
Constructor and Description |
---|
TelemetrySinkModule(Protocol protocol) |
Modifier and Type | Method and Description |
---|---|
AggregationPolicy<TelemetryMessage,TelemetryProtos.TelemetryMessageLog,TelemetryProtos.TelemetryMessageLog.Builder> |
getAggregationPolicy()
Defines how messages should be combined, and when they
should be "released".
|
AsyncPolicy |
getAsyncPolicy()
Defines how messages should be asynchronously dispatched.
|
DistPollerDao |
getDistPollerDao() |
String |
getId()
Globally unique identifier.
|
int |
getNumConsumerThreads()
The number of threads used to consume from the broker.
|
byte[] |
marshal(TelemetryProtos.TelemetryMessageLog message)
Marshals the message to a byte array.
|
void |
setDistPollerDao(DistPollerDao distPollerDao) |
TelemetryProtos.TelemetryMessageLog |
unmarshal(byte[] bytes)
Unmarshals the message from a byte array.
|
public TelemetrySinkModule(Protocol protocol)
public String getId()
SinkModule
getId
in interface SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
public int getNumConsumerThreads()
SinkModule
getNumConsumerThreads
in interface SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
public byte[] marshal(TelemetryProtos.TelemetryMessageLog message)
SinkModule
marshal
in interface SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
public TelemetryProtos.TelemetryMessageLog unmarshal(byte[] bytes)
SinkModule
unmarshal
in interface SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
public AggregationPolicy<TelemetryMessage,TelemetryProtos.TelemetryMessageLog,TelemetryProtos.TelemetryMessageLog.Builder> getAggregationPolicy()
SinkModule
null
.getAggregationPolicy
in interface SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
AggregationPolicy
used to combine messages, or null
if the messages should not be combined.public AsyncPolicy getAsyncPolicy()
SinkModule
getAsyncPolicy
in interface SinkModule<TelemetryMessage,TelemetryProtos.TelemetryMessageLog>
AsyncPolicy
used when asynchronously dispatching
messages for this module.public DistPollerDao getDistPollerDao()
public void setDistPollerDao(DistPollerDao distPollerDao)
Copyright © 2018. All rights reserved.