Uses of Class
io.confluent.ksql.api.client.KsqlObject

Packages that use KsqlObject

Package	Description
io.confluent.ksql.api.client

Uses of KsqlObject in io.confluent.ksql.api.client

Methods in io.confluent.ksql.api.client that return KsqlObject

Modifier and Type	Method	Description
KsqlObject	Row.asObject()	Returns the data in this row represented as a KsqlObject where keys are column names and values are column values.
KsqlObject	KsqlObject.copy()	Returns a copy of this.
static KsqlObject	KsqlObject.fromArray(List<String> keys, KsqlArray values)
KsqlObject	KsqlArray.getKsqlObject(int pos)	Returns the value at a specified index as a KsqlObject.
KsqlObject	KsqlObject.getKsqlObject(String key)	Returns the value associated with the specified key as a KsqlObject.
KsqlObject	Row.getKsqlObject(int columnIndex)	Returns the value for a particular column of the Row as a KsqlObject.
KsqlObject	Row.getKsqlObject(String columnName)	Returns the value for a particular column of the Row as a KsqlObject.
KsqlObject	KsqlObject.mergeIn(KsqlObject other)	Adds entries from the specified KsqlObject into this instance.
KsqlObject	KsqlObject.put(String key, byte[] value)
KsqlObject	KsqlObject.put(String key, KsqlArray value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, KsqlObject value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, Boolean value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, Double value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, Integer value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, Long value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, Object value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, String value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.put(String key, BigDecimal value)	Adds an entry for the specified key and value to the map.
KsqlObject	KsqlObject.putNull(String key)	Adds an entry for the specified key with null value to the map.

Methods in io.confluent.ksql.api.client with parameters of type KsqlObject

Modifier and Type	Method	Description
boolean	InsertsPublisher.accept(KsqlObject row)	Provides a new row for insertion.
KsqlArray	KsqlArray.add(KsqlObject value)	Appends the specified value to the end of the array.
CompletableFuture<Void>	Client.insertInto(String streamName, KsqlObject row)	Inserts a row into a ksqlDB stream.
KsqlObject	KsqlObject.mergeIn(KsqlObject other)	Adds entries from the specified KsqlObject into this instance.
KsqlObject	KsqlObject.put(String key, KsqlObject value)	Adds an entry for the specified key and value to the map.

Method parameters in io.confluent.ksql.api.client with type arguments of type KsqlObject

Modifier and Type	Method	Description
CompletableFuture<AcksPublisher>	Client.streamInserts(String streamName, org.reactivestreams.Publisher<KsqlObject> insertsPublisher)	Inserts rows into a ksqlDB stream.
void	InsertsPublisher.subscribe(org.reactivestreams.Subscriber<? super KsqlObject> subscriber)