S
- stream keyy type.public static class StreamRecords.RecordBuilder<S> extends Object
Record
.Modifier and Type | Method and Description |
---|---|
<STREAM_KEY> |
in(STREAM_KEY stream)
Configure a stream key.
|
ByteBufferRecord |
ofBuffer(Map<ByteBuffer,ByteBuffer> value) |
ByteRecord |
ofBytes(Map<byte[],byte[]> value) |
<K,V> MapRecord<S,K,V> |
ofMap(Map<K,V> map)
Create a
MapRecord . |
<V> ObjectRecord<S,V> |
ofObject(V value)
Create an
ObjectRecord . |
StringRecord |
ofStrings(Map<String,String> map)
Create a
StringRecord . |
StreamRecords.RecordBuilder<S> |
withId(RecordId id)
Configure a
RecordId . |
StreamRecords.RecordBuilder<S> |
withId(String id)
Configure a record Id given a
String . |
public <STREAM_KEY> StreamRecords.RecordBuilder<STREAM_KEY> in(STREAM_KEY stream)
STREAM_KEY
- stream
- the stream key, must not be null.StreamRecords.RecordBuilder
.public StreamRecords.RecordBuilder<S> withId(String id)
String
. Associates a user-supplied record id instead of using
server-generated record Id's.id
- the record id.StreamRecords.RecordBuilder
.RecordId
public StreamRecords.RecordBuilder<S> withId(RecordId id)
RecordId
. Associates a user-supplied record id instead of using server-generated record Id's.id
- the record id.StreamRecords.RecordBuilder
.public <K,V> MapRecord<S,K,V> ofMap(Map<K,V> map)
MapRecord
.K
- V
- map
- MapRecord
.public StringRecord ofStrings(Map<String,String> map)
StringRecord
.map
- StringRecord
.MapRecord
public <V> ObjectRecord<S,V> ofObject(V value)
ObjectRecord
.V
- value
- ObjectRecord
.public ByteRecord ofBytes(Map<byte[],byte[]> value)
value
- ByteRecord
.public ByteBufferRecord ofBuffer(Map<ByteBuffer,ByteBuffer> value)
value
- ByteBufferRecord
.Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.