Package com.influxdb.query.internal

Class FluxCsvParser

java.lang.Object

com.influxdb.query.internal.FluxCsvParser

public class FluxCsvParser
extends Object

This class us used to construct FluxResult from CSV.

See Also:

• com.influxdb.query

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FluxCsvParser.FluxCsvState
static class	FluxCsvParser.FluxRecordOrTable
static interface	FluxCsvParser.FluxResponseConsumer
class	FluxCsvParser.FluxResponseConsumerTable
static enum	FluxCsvParser.ResponseMetadataMode

Constructor Summary

Constructors

Constructor	Description
FluxCsvParser()
FluxCsvParser(FluxCsvParser.ResponseMetadataMode responseMetadataMode)

Method Summary

Modifier and Type	Method	Description
void	parseFluxResponse(okio.BufferedSource bufferedSource, Cancellable cancellable, FluxCsvParser.FluxResponseConsumer consumer)	Parse Flux CSV response to FluxCsvParser.FluxResponseConsumer.
FluxCsvParser.FluxRecordOrTable	parseNextResponse(FluxCsvParser.FluxCsvState state)	Parse actual FluxCsvParser.FluxCsvState.csvRecord into FluxTable or FluxRecord.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FluxCsvParser

public FluxCsvParser()

FluxCsvParser

public FluxCsvParser(@Nonnull
 FluxCsvParser.ResponseMetadataMode responseMetadataMode)

Method Details

parseFluxResponse

public void parseFluxResponse(@Nonnull
 okio.BufferedSource bufferedSource,
 @Nonnull
 Cancellable cancellable,
 @Nonnull
 FluxCsvParser.FluxResponseConsumer consumer)
                       throws IOException

Parse Flux CSV response to FluxCsvParser.FluxResponseConsumer.

Parameters:

bufferedSource - with data

cancellable - to cancel parsing

consumer - to accept FluxTables and FluxRecords

Throws:

IOException - If there is a problem with reading CSV

parseNextResponse

@Nonnull
public FluxCsvParser.FluxRecordOrTable parseNextResponse(@Nonnull
 FluxCsvParser.FluxCsvState state)

Parse actual FluxCsvParser.FluxCsvState.csvRecord into FluxTable or FluxRecord.

Parameters:

state - current state of parsing

Returns:

table or record or both