com.datastax.oss/native-protocol/1.4.12

https://github.com/datastax/native-protocol: A set of Java types representing the frames and messages of the Apache Cassandra® native protocol, with the associated serialization and deserialization logic (this is a third-party implementation, not related to the Apache Cassandra project)

Apache 2

Various (DataStax)

directory

Dependencies

java/11

directory

Declarations

com
- datastax
  - dse
    - protocol
      - internal
        
        DseProtocolConstants
        
        Version
        
        DSE_V1: int
        
        DSE_V2: int
        
        MIN: int
        
        MAX: int
        
        BETA: int
        
        ErrorCode
        
        CLIENT_WRITE_FAILURE: int
        
        Opcode
        
        REVISE_REQUEST: int
        
        QueryFlag
        
        PAGE_SIZE_BYTES: int
        
        CONTINUOUS_PAGING: int
        
        RowsFlag
        
        CONTINUOUS_PAGING: int
        
        LAST_CONTINUOUS_PAGE: int
        
        RevisionType
        
        MORE_CONTINUOUS_PAGES: int
        
        CANCEL_CONTINUOUS_PAGING: int
        
        DseProtocolV1ClientCodecs
        
        registerCodecs(Registry): void
        
        DseProtocolV1ServerCodecs
        
        registerCodecs(Registry): void
        
        DseProtocolV2ClientCodecs
        
        registerCodecs(Registry): void
        
        DseProtocolV2ServerCodecs
        
        registerCodecs(Registry): void
        
        ProtocolV4ClientCodecsForDse
        
        registerCodecs(Registry): void
        
        request
        
        DseBatchCodec
        
        DseBatchCodec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        DseExecuteCodec
        
        optionsCodec: Codec
        
        DseExecuteCodec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        DsePrepareCodec
        
        DsePrepareCodec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        DseQueryCodec
        
        DseQueryCodec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        DseQueryCodecV4
        
        DseQueryCodecV4(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        RawBytesQuery
        
        query: byte[]
        
        options: DseQueryOptions
        
        RawBytesQuery(byte[], DseQueryOptions): void
        
        toString(): String
        
        Revise
        
        cancelContinuousPaging(int): Revise
        
        requestMoreContinuousPages(int, int): Revise
        
        revisionType: int
        
        streamId: int
        
        nextPages: int
        
        Revise(int, int, int): void
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        query
        
        ContinuousPagingOptions
        
        maxPages: int
        
        pagesPerSecond: int
        
        nextPages: int
        
        ContinuousPagingOptions(int, int, int): void
        
        DseQueryOptions
        
        isPageSizeInBytes: boolean
        
        continuousPagingOptions: ContinuousPagingOptions
        
        DseQueryOptions(int, List<ByteBuffer>, Map<String, ByteBuffer>, boolean, int, ByteBuffer, int, long, String, boolean, ContinuousPagingOptions): void
        
        computeFlags(List<ByteBuffer>, Map<String, ByteBuffer>, boolean, int, ByteBuffer, int, long, String, boolean, ContinuousPagingOptions): int
        
        DseQueryOptions(int, int, List<ByteBuffer>, Map<String, ByteBuffer>, boolean, int, ByteBuffer, int, long, String, boolean, ContinuousPagingOptions): void
        
        DseQueryOptionsCodec
        
        DseQueryOptionsCodec(int): void
        
        encode(Object, QueryOptions, PrimitiveCodec<Object>): void
        
        encodedSize(QueryOptions): int
        
        decode(Object, PrimitiveCodec<Object>): QueryOptions
        
        response
        
        result
        
        DsePreparedSubCodec
        
        DsePreparedSubCodec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        DseRowsMetadata
        
        decode(Object, PrimitiveCodec<Object>, boolean, int): DseRowsMetadata
        
        continuousPageNumber: int
        
        isLastContinuousPage: boolean
        
        DseRowsMetadata(List<ColumnSpec>, ByteBuffer, int[], byte[], int, boolean): void
        
        DseRowsMetadata(int, ByteBuffer, int[], byte[], int, boolean): void
        
        DseRowsMetadata(int, List<ColumnSpec>, int, ByteBuffer, int[], byte[], int, boolean): void
        
        computeFlags(boolean, List<ColumnSpec>, ByteBuffer, byte[], int, boolean): int
        
        encode(Object, PrimitiveCodec<Object>, boolean, int): void
        
        encodedSize(boolean, int): int
        
        DseRowsSubCodec
        
        DseRowsSubCodec(int): void
        
        decode(Object, PrimitiveCodec<Object>): Message
  - oss
    - protocol
      - internal
        
        Compressor
        
        none(): Compressor<Object>
        
        algorithm(): String
        
        compress(Object): Object
        
        decompress(Object): Object
        
        compressWithoutLength(Object): Object
        
        decompressWithoutLength(Object, int): Object
        
        CrcMismatchException
        
        serialVersionUID: long
        
        CrcMismatchException(String): void
        
        Frame
        
        NO_PAYLOAD: Map<String, ByteBuffer>
        
        forRequest(int, int, boolean, Map<String, ByteBuffer>, Message): Frame
        
        forResponse(int, int, UUID, Map<String, ByteBuffer>, List<String>, Message): Frame
        
        protocolVersion: int
        
        beta: boolean
        
        streamId: int
        
        tracingId: UUID
        
        tracing: boolean
        
        size: int
        
        compressedSize: int
        
        customPayload: Map<String, ByteBuffer>
        
        warnings: List<String>
        
        message: Message
        
        Frame(int, boolean, int, boolean, UUID, int, int, Map<String, ByteBuffer>, List<String>, Message): void
        
        Frame(int, boolean, int, boolean, UUID, Map<String, ByteBuffer>, List<String>, Message): void
        
        FrameCodec
        
        V3_ENCODED_HEADER_SIZE: int
        
        defaultClient(PrimitiveCodec<Object>, Compressor<Object>): FrameCodec<Object>
        
        defaultServer(PrimitiveCodec<Object>, Compressor<Object>): FrameCodec<Object>
        
        primitiveCodec: PrimitiveCodec<Object>
        
        compressor: Compressor<Object>
        
        encoders: IntIntMap<Codec>
        
        decoders: IntIntMap<Codec>
        
        FrameCodec(PrimitiveCodec<Object>, Compressor<Object>, CodecGroup[]): void
        
        $1
        
        addCodec(Codec): Registry
        
        addEncoder(Codec): Registry
        
        addDecoder(Codec): Registry
        
        encode(Frame): Object
        
        encodeInto(Frame, int, Object): void
        
        getMessageEncoder(Frame): Codec
        
        computeFlags(Frame): int
        
        encodeInto(Frame, int, int, Codec, Object): void
        
        encodeHeaderInto(Frame, int, int, Object): void
        
        encodeBodyInto(Frame, Codec, Object): void
        
        encodeTracingId(UUID, Object): void
        
        encodeCustomPayload(Map<String, ByteBuffer>, Object): void
        
        encodeWarnings(List<String>, Object): void
        
        encodedHeaderSize(Frame): int
        
        encodedBodySize(Frame): int
        
        decodeBodySize(Object): int
        
        decode(Object): Frame
        
        readStreamId(Object): int
        
        CodecGroup
        
        Registry
        
        addCodec(Codec): Registry
        
        addEncoder(Codec): Registry
        
        addDecoder(Codec): Registry
        
        registerCodecs(Registry): void
        
        Message
        
        isResponse: boolean
        
        opcode: int
        
        Message(boolean, int): void
        
        Codec
        
        opcode: int
        
        protocolVersion: int
        
        Codec(int, int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        NoopCompressor
        
        algorithm(): String
        
        compress(Object): Object
        
        decompress(Object): Object
        
        compressWithoutLength(Object): Object
        
        decompressWithoutLength(Object, int): Object
        
        PrimitiveCodec
        
        allocate(int): Object
        
        release(Object): void
        
        sizeOf(Object): int
        
        concat(Object, Object): Object
        
        markReaderIndex(Object): void
        
        resetReaderIndex(Object): void
        
        readByte(Object): byte
        
        readInt(Object): int
        
        readInt(Object, int): int
        
        readInetAddr(Object): InetAddress
        
        readLong(Object): long
        
        readUnsignedShort(Object): int
        
        readBytes(Object): ByteBuffer
        
        readShortBytes(Object): byte[]
        
        readString(Object): String
        
        readLongString(Object): String
        
        readRetainedSlice(Object, int): Object
        
        updateCrc(Object, CRC32): void
        
        readUuid(Object): UUID
        
        readStringList(Object): List<String>
        
        readStringMap(Object): Map<String, String>
        
        readStringMultimap(Object): Map<String, List<String>>
        
        readBytesMap(Object): Map<String, ByteBuffer>
        
        readInet(Object): InetSocketAddress
        
        writeByte(byte, Object): void
        
        writeInt(int, Object): void
        
        writeInetAddr(InetAddress, Object): void
        
        writeLong(long, Object): void
        
        writeUnsignedShort(int, Object): void
        
        writeString(String, Object): void
        
        writeLongString(String, Object): void
        
        writeUuid(UUID, Object): void
        
        writeBytes(ByteBuffer, Object): void
        
        writeBytes(byte[], Object): void
        
        writeShortBytes(byte[], Object): void
        
        writeStringList(List<String>, Object): void
        
        writeStringMap(Map<String, String>, Object): void
        
        writeStringMultimap(Map<String, List<String>>, Object): void
        
        writeBytesMap(Map<String, ByteBuffer>, Object): void
        
        writeInet(InetSocketAddress, Object): void
        
        PrimitiveSizes
        
        SHORT: int
        
        INT: int
        
        BYTE: int
        
        LONG: int
        
        UUID: int
        
        PrimitiveSizes(): void
        
        sizeOfString(String): int
        
        sizeOfLongString(String): int
        
        sizeOfStringList(List<String>): int
        
        sizeOfBytes(byte[]): int
        
        sizeOfBytes(ByteBuffer): int
        
        sizeOfShortBytes(byte[]): int
        
        sizeOfShortBytes(ByteBuffer): int
        
        sizeOfStringMap(Map<String, String>): int
        
        sizeOfStringMultimap(Map<String, List<String>>): int
        
        sizeOfBytesMap(Map<String, ByteBuffer>): int
        
        encodedUTF8Length(String): int
        
        sizeOfInet(InetSocketAddress): int
        
        sizeOfInetAddr(InetAddress): int
        
        ProtocolConstants
        
        UNSET_VALUE: ByteBuffer
        
        Version
        
        V3: int
        
        V4: int
        
        V5: int
        
        MIN: int
        
        MAX: int
        
        BETA: int
        
        Opcode
        
        ERROR: int
        
        STARTUP: int
        
        READY: int
        
        AUTHENTICATE: int
        
        OPTIONS: int
        
        SUPPORTED: int
        
        QUERY: int
        
        RESULT: int
        
        PREPARE: int
        
        EXECUTE: int
        
        REGISTER: int
        
        EVENT: int
        
        BATCH: int
        
        AUTH_CHALLENGE: int
        
        AUTH_RESPONSE: int
        
        AUTH_SUCCESS: int
        
        ResultKind
        
        VOID: int
        
        ROWS: int
        
        SET_KEYSPACE: int
        
        PREPARED: int
        
        SCHEMA_CHANGE: int
        
        ErrorCode
        
        SERVER_ERROR: int
        
        PROTOCOL_ERROR: int
        
        AUTH_ERROR: int
        
        UNAVAILABLE: int
        
        OVERLOADED: int
        
        IS_BOOTSTRAPPING: int
        
        TRUNCATE_ERROR: int
        
        WRITE_TIMEOUT: int
        
        READ_TIMEOUT: int
        
        READ_FAILURE: int
        
        FUNCTION_FAILURE: int
        
        WRITE_FAILURE: int
        
        SYNTAX_ERROR: int
        
        UNAUTHORIZED: int
        
        INVALID: int
        
        CONFIG_ERROR: int
        
        ALREADY_EXISTS: int
        
        UNPREPARED: int
        
        ConsistencyLevel
        
        ANY: int
        
        ONE: int
        
        TWO: int
        
        THREE: int
        
        QUORUM: int
        
        ALL: int
        
        LOCAL_QUORUM: int
        
        EACH_QUORUM: int
        
        SERIAL: int
        
        LOCAL_SERIAL: int
        
        LOCAL_ONE: int
        
        WriteType
        
        SIMPLE: String
        
        BATCH: String
        
        UNLOGGED_BATCH: String
        
        COUNTER: String
        
        BATCH_LOG: String
        
        VIEW: String
        
        CDC: String
        
        DataType
        
        CUSTOM: int
        
        ASCII: int
        
        BIGINT: int
        
        BLOB: int
        
        BOOLEAN: int
        
        COUNTER: int
        
        DECIMAL: int
        
        DOUBLE: int
        
        FLOAT: int
        
        INT: int
        
        TIMESTAMP: int
        
        UUID: int
        
        VARCHAR: int
        
        VARINT: int
        
        TIMEUUID: int
        
        INET: int
        
        DATE: int
        
        TIME: int
        
        SMALLINT: int
        
        TINYINT: int
        
        DURATION: int
        
        LIST: int
        
        MAP: int
        
        SET: int
        
        UDT: int
        
        TUPLE: int
        
        EventType
        
        TOPOLOGY_CHANGE: String
        
        STATUS_CHANGE: String
        
        SCHEMA_CHANGE: String
        
        SchemaChangeType
        
        CREATED: String
        
        UPDATED: String
        
        DROPPED: String
        
        SchemaChangeTarget
        
        KEYSPACE: String
        
        TABLE: String
        
        TYPE: String
        
        FUNCTION: String
        
        AGGREGATE: String
        
        TopologyChangeType
        
        NEW_NODE: String
        
        REMOVED_NODE: String
        
        StatusChangeType
        
        UP: String
        
        DOWN: String
        
        BatchType
        
        LOGGED: byte
        
        UNLOGGED: byte
        
        COUNTER: byte
        
        FrameFlag
        
        COMPRESSED: int
        
        TRACING: int
        
        CUSTOM_PAYLOAD: int
        
        WARNING: int
        
        USE_BETA: int
        
        QueryFlag
        
        VALUES: int
        
        SKIP_METADATA: int
        
        PAGE_SIZE: int
        
        PAGING_STATE: int
        
        SERIAL_CONSISTENCY: int
        
        DEFAULT_TIMESTAMP: int
        
        VALUE_NAMES: int
        
        WITH_KEYSPACE: int
        
        NOW_IN_SECONDS: int
        
        RowsFlag
        
        GLOBAL_TABLES_SPEC: int
        
        HAS_MORE_PAGES: int
        
        NO_METADATA: int
        
        METADATA_CHANGED: int
        
        ProtocolErrors
        
        check(boolean, String, Object[]): void
        
        ProtocolV3ClientCodecs
        
        registerCodecs(Registry): void
        
        ProtocolV3ServerCodecs
        
        registerCodecs(Registry): void
        
        ProtocolV4ClientCodecs
        
        registerCodecs(Registry): void
        
        ProtocolV4ServerCodecs
        
        registerCodecs(Registry): void
        
        ProtocolV5ClientCodecs
        
        registerCodecs(Registry): void
        
        ProtocolV5ServerCodecs
        
        registerCodecs(Registry): void
        
        Segment
        
        MAX_PAYLOAD_LENGTH: int
        
        payload: Object
        
        isSelfContained: boolean
        
        Segment(Object, boolean): void
        
        SegmentBuilder
        
        primitiveCodec: PrimitiveCodec<Object>
        
        frameCodec: FrameCodec<Object>
        
        maxPayloadLength: int
        
        currentPayloadFrames: List<Frame>
        
        currentPayloadStates: List<Object>
        
        currentPayloadLength: int
        
        SegmentBuilder(PrimitiveCodec<Object>, FrameCodec<Object>): void
        
        SegmentBuilder(PrimitiveCodec<Object>, FrameCodec<Object>, int): void
        
        mergeStates(List<Object>): Object
        
        splitState(Object, int): List<Object>
        
        processSegment(Segment<Object>, Object): void
        
        addFrame(Frame, Object): void
        
        flush(): void
        
        onLargeFrameSplit(Frame, int, int): void
        
        onSegmentFull(Frame, int, int, int): void
        
        onSmallFrameAdded(Frame, int, int, int): void
        
        onLastSegmentFlushed(int, int): void
        
        processCurrentPayload(): void
        
        resetCurrentPayload(): void
        
        SegmentCodec
        
        COMPRESSED_HEADER_LENGTH: int
        
        UNCOMPRESSED_HEADER_LENGTH: int
        
        CRC24_LENGTH: int
        
        CRC32_LENGTH: int
        
        primitiveCodec: PrimitiveCodec<Object>
        
        compressor: Compressor<Object>
        
        compress: boolean
        
        SegmentCodec(PrimitiveCodec<Object>, Compressor<Object>): void
        
        headerLength(): int
        
        encode(Segment<Object>, List<Object>): void
        
        encodeHeader(int, int, boolean): Object
        
        decodeHeader(Object): Header
        
        decode(Header, Object): Segment<Object>
        
        Header
        
        payloadLength: int
        
        uncompressedPayloadLength: int
        
        isSelfContained: boolean
        
        Header(int, int, boolean): void
        
        request
        
        AuthResponse
        
        token: ByteBuffer
        
        AuthResponse(ByteBuffer): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Batch
        
        type: byte
        
        queriesOrIds: List<Object>
        
        values: List<List<ByteBuffer>>
        
        consistency: int
        
        serialConsistency: int
        
        defaultTimestamp: long
        
        keyspace: String
        
        nowInSeconds: int
        
        flags: int
        
        Batch(int, byte, List<Object>, List<List<ByteBuffer>>, int, int, long, String, int): void
        
        Batch(byte, List<Object>, List<List<ByteBuffer>>, int, int, long, String, int): void
        
        toString(): String
        
        computeFlags(int, long, String, int): int
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Execute
        
        queryId: byte[]
        
        resultMetadataId: byte[]
        
        options: QueryOptions
        
        Execute(byte[], byte[], QueryOptions): void
        
        Execute(byte[], QueryOptions): void
        
        toString(): String
        
        Codec
        
        optionsCodec: Codec
        
        Codec(int, Codec): void
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Options
        
        INSTANCE: Options
        
        Options(): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Prepare
        
        cqlQuery: String
        
        keyspace: String
        
        Prepare(String, String): void
        
        Prepare(String): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Query
        
        query: String
        
        options: QueryOptions
        
        Query(String, QueryOptions): void
        
        Query(String): void
        
        toString(): String
        
        Codec
        
        optionsCodec: Codec
        
        Codec(int, Codec): void
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Register
        
        eventTypes: List<String>
        
        Register(List<String>): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Startup
        
        CQL_VERSION_KEY: String
        
        COMPRESSION_KEY: String
        
        CQL_VERSION: String
        
        options: Map<String, String>
        
        Startup(String): void
        
        Startup(): void
        
        Startup(Map<String, String>): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        query
        
        QueryOptions
        
        Codec
        
        NO_DEFAULT_TIMESTAMP: long
        
        NO_NOW_IN_SECONDS: int
        
        DEFAULT: QueryOptions
        
        flags: int
        
        consistency: int
        
        positionalValues: List<ByteBuffer>
        
        namedValues: Map<String, ByteBuffer>
        
        skipMetadata: boolean
        
        pageSize: int
        
        pagingState: ByteBuffer
        
        serialConsistency: int
        
        defaultTimestamp: long
        
        keyspace: String
        
        nowInSeconds: int
        
        QueryOptions(int, int, List<ByteBuffer>, Map<String, ByteBuffer>, boolean, int, ByteBuffer, int, long, String, int): void
        
        QueryOptions(int, List<ByteBuffer>, Map<String, ByteBuffer>, boolean, int, ByteBuffer, int, long, String, int): void
        
        computeFlags(List<ByteBuffer>, Map<String, ByteBuffer>, boolean, int, ByteBuffer, int, long, String, int): int
        
        toString(): String
        
        queryFlagsSize(int): int
        
        Values
        
        writePositionalValues(List<ByteBuffer>, Object, PrimitiveCodec<Object>): void
        
        sizeOfPositionalValues(List<ByteBuffer>): int
        
        writeNamedValues(Map<String, ByteBuffer>, Object, PrimitiveCodec<Object>): void
        
        sizeOfNamedValues(Map<String, ByteBuffer>): int
        
        writeValue(ByteBuffer, Object, PrimitiveCodec<Object>): void
        
        sizeOfValue(ByteBuffer): int
        
        readPositionalValues(Object, PrimitiveCodec<Object>): List<ByteBuffer>
        
        readNamedValues(Object, PrimitiveCodec<Object>): Map<String, ByteBuffer>
        
        readValue(Object, PrimitiveCodec<Object>): ByteBuffer
        
        response
        
        AuthChallenge
        
        token: ByteBuffer
        
        AuthChallenge(ByteBuffer): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        AuthSuccess
        
        token: ByteBuffer
        
        AuthSuccess(ByteBuffer): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Authenticate
        
        authenticator: String
        
        Authenticate(String): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Error
        
        code: int
        
        message: String
        
        Error(int, String): void
        
        toString(): String
        
        Codec
        
        subCodecs: IntMap<SubCodec>
        
        Codec(int, SubCodec[]): void
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        getSubCodec(int): SubCodec
        
        SubCodec
        
        errorCode: int
        
        protocolVersion: int
        
        SubCodec(int, int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        SingleMessageSubCodec
        
        SingleMessageSubCodec(int, int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Event
        
        type: String
        
        Event(String): void
        
        Codec
        
        subDecoders: Map<String, SubCodec>
        
        Codec(int, SubCodec[]): void
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        getSubCodec(String): SubCodec
        
        SubCodec
        
        protocolVersion: int
        
        type: String
        
        SubCodec(String, int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Ready
        
        Ready(): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Result
        
        kind: int
        
        Result(int): void
        
        Codec
        
        subDecoders: IntMap<SubCodec>
        
        Codec(int, SubCodec[]): void
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        getSubCodec(int): SubCodec
        
        SubCodec
        
        kind: int
        
        protocolVersion: int
        
        SubCodec(int, int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        Supported
        
        options: Map<String, List<String>>
        
        Supported(Map<String, List<String>>): void
        
        toString(): String
        
        Codec
        
        Codec(int): void
        
        encode(Object, Message, PrimitiveCodec<Object>): void
        
        encodedSize(Message): int
        
        decode(Object, PrimitiveCodec<Object>): Message
        
        error
        
        AlreadyExists
        
        keyspace: String
        
        table: String
        
        AlreadyExists(String, String, String): void
        
        SubCodec
        
        FunctionFailure
        
        keyspace: String
        
        function: String
        
        argTypes: List<String>
        
        FunctionFailure(String, String, String, List<String>): void
        
        SubCodec
        
        ReadFailure
        
        consistencyLevel: int
        
        received: int
        
        blockFor: int
        
        numFailures: int
        
        reasonMap: Map<InetAddress, Integer>
        
        dataPresent: boolean
        
        ReadFailure(String, int, int, int, int, Map<InetAddress, Integer>, boolean): void
        
        SubCodec
        
        ReadTimeout
        
        consistencyLevel: int
        
        received: int
        
        blockFor: int
        
        dataPresent: boolean
        
        ReadTimeout(String, int, int, int, boolean): void
        
        SubCodec
        
        Unavailable
        
        consistencyLevel: int
        
        required: int
        
        alive: int
        
        Unavailable(String, int, int, int): void
        
        SubCodec
        
        Unprepared
        
        id: byte[]
        
        Unprepared(String, byte[]): void
        
        SubCodec
        
        WriteFailure
        
        consistencyLevel: int
        
        received: int
        
        blockFor: int
        
        numFailures: int
        
        reasonMap: Map<InetAddress, Integer>
        
        writeType: String
        
        WriteFailure(String, int, int, int, int, Map<InetAddress, Integer>, String): void
        
        SubCodec
        
        WriteTimeout
        
        consistencyLevel: int
        
        received: int
        
        blockFor: int
        
        writeType: String
        
        WriteTimeout(String, int, int, int, String): void
        
        SubCodec
        
        event
        
        SchemaChangeEvent
        
        changeType: String
        
        target: String
        
        keyspace: String
        
        object: String
        
        arguments: List<String>
        
        SchemaChangeEvent(String, String, String, String, List<String>): void
        
        toString(): String
        
        SubCodec
        
        StatusChangeEvent
        
        changeType: String
        
        address: InetSocketAddress
        
        StatusChangeEvent(String, InetSocketAddress): void
        
        toString(): String
        
        SubCodec
        
        TopologyChangeEvent
        
        changeType: String
        
        address: InetSocketAddress
        
        TopologyChangeEvent(String, InetSocketAddress): void
        
        toString(): String
        
        SubCodec
        
        result
        
        ColumnSpec
        
        ksName: String
        
        tableName: String
        
        name: String
        
        index: int
        
        type: RawType
        
        ColumnSpec(String, String, String, int, RawType): void
        
        equals(Object): boolean
        
        hashCode(): int
        
        DefaultRows
        
        metadata: RowsMetadata
        
        data: Queue<List<ByteBuffer>>
        
        DefaultRows(RowsMetadata, Queue<List<ByteBuffer>>): void
        
        getMetadata(): RowsMetadata
        
        getData(): Queue<List<ByteBuffer>>
        
        toString(): String
        
        SubCodec
        
        Prepared
        
        resultMetadata: RowsMetadata
        
        preparedQueryId: byte[]
        
        resultMetadataId: byte[]
        
        variablesMetadata: RowsMetadata
        
        Prepared(byte[], byte[], RowsMetadata, RowsMetadata): void
        
        toString(): String
        
        SubCodec
        
        RawType
        
        RawMap
        
        decode(Object, PrimitiveCodec<Object>, int): RawType
        
        id: int
        
        RawType(int): void
        
        encode(Object, PrimitiveCodec<Object>, int): void
        
        encodedSize(int): int
        
        equals(Object): boolean
        
        hashCode(): int
        
        RawPrimitive
        
        RawCustom
        
        RawList
        
        RawSet
        
        RawUdt
        
        RawTuple
        
        PRIMITIVES: Map<Integer, RawType>
        
        static class initializer
        
        Rows
        
        getMetadata(): RowsMetadata
        
        getData(): Queue<List<ByteBuffer>>
        
        Rows(): void
        
        RowsMetadata
        
        columnSpecs: List<ColumnSpec>
        
        columnCount: int
        
        pagingState: ByteBuffer
        
        pkIndices: int[]
        
        newResultMetadataId: byte[]
        
        flags: int
        
        RowsMetadata(List<ColumnSpec>, ByteBuffer, int[], byte[]): void
        
        RowsMetadata(int, ByteBuffer, int[], byte[]): void
        
        RowsMetadata(int, List<ColumnSpec>, int, ByteBuffer, int[], byte[]): void
        
        computeFlags(boolean, List<ColumnSpec>, ByteBuffer, byte[]): int
        
        encode(Object, PrimitiveCodec<Object>, boolean, int): void
        
        encodedSize(boolean, int): int
        
        decode(Object, PrimitiveCodec<Object>, boolean, int): RowsMetadata
        
        haveSameTable(List<ColumnSpec>): boolean
        
        SchemaChange
        
        changeType: String
        
        target: String
        
        keyspace: String
        
        object: String
        
        arguments: List<String>
        
        SchemaChange(String, String, String, String, List<String>): void
        
        toString(): String
        
        SubCodec
        
        SetKeyspace
        
        keyspace: String
        
        SetKeyspace(String): void
        
        toString(): String
        
        SubCodec
        
        Void
        
        INSTANCE: Void
        
        Void(): void
        
        toString(): String
        
        SubCodec
        
        util
        
        Bytes
        
        Bytes(): void
        
        charToByte: byte[]
        
        byteToChar: char[]
        
        static class initializer
        
        toHexString(ByteBuffer): String
        
        toRawHexString(ByteBuffer, char[], int): String
        
        toHexString(byte[]): String
        
        fromHexString(String): ByteBuffer
        
        fromRawHexString(String, int): byte[]
        
        getArray(ByteBuffer): byte[]
        
        erase(ByteBuffer): void
        
        Crc
        
        crc32: ThreadLocal<CRC32>
        
        initialBytes: byte[]
        
        computeCrc32(Object, PrimitiveCodec<Object>): int
        
        newCrc32(): CRC32
        
        CRC24_INIT: int
        
        CRC24_POLY: int
        
        computeCrc24(long, int): int
        
        Flags
        
        contains(int, int): boolean
        
        add(int, int): int
        
        IntIntMap
        
        builder(): Builder<Object>
        
        outer: IntMap<IntMap<Object>>
        
        IntIntMap(IntMap<IntMap<Object>>): void
        
        get(int, int): Object
        
        Builder
        
        innerBuilders: Map<Integer, Builder<Object>>
        
        put(int, int, Object): Builder<Object>
        
        build(): IntIntMap<Object>
        
        IntMap
        
        builder(): Builder<Object>
        
        values: Object[]
        
        IntMap(Set<Entry<Integer, Object>>): void
        
        get(int): Object
        
        Builder
        
        map: Map<Integer, Object>
        
        put(int, Object): Builder<Object>
        
        build(): IntMap<Object>
        
        collection
        
        NullAllowingImmutableList
        
        EMPTY: NullAllowingImmutableList
        
        of(Object[]): NullAllowingImmutableList<Object>
        
        NullAllowingImmutableList(Object[]): void
        
        of(): NullAllowingImmutableList<Object>
        
        of(Object): NullAllowingImmutableList<Object>
        
        of(Object, Object): NullAllowingImmutableList<Object>
        
        of(Object, Object, Object): NullAllowingImmutableList<Object>
        
        copyOf(Iterable<Object>): NullAllowingImmutableList<Object>
        
        builder(): Builder<Object>
        
        builder(int): Builder<Object>
        
        elements: Object[]
        
        get(int): Object
        
        size(): int
        
        toArray(Iterable<Object>): Object[]
        
        Builder
        
        NullAllowingImmutableMap
        
        EMPTY: NullAllowingImmutableMap
        
        of(): NullAllowingImmutableMap<Object, Object>
        
        of(Object, Object): NullAllowingImmutableMap<Object, Object>
        
        of(Object, Object, Object, Object): NullAllowingImmutableMap<Object, Object>
        
        of(Object, Object, Object, Object, Object, Object): NullAllowingImmutableMap<Object, Object>
        
        copyOf(Map<Object, Object>): NullAllowingImmutableMap<Object, Object>
        
        builder(): Builder<Object, Object>
        
        builder(int): Builder<Object, Object>
        
        entries: NullAllowingImmutableSet<Entry<Object, Object>>
        
        NullAllowingImmutableMap(NullAllowingImmutableSet<Entry<Object, Object>>): void
        
        entrySet(): Set<Entry<Object, Object>>
        
        containsValue(Object): boolean
        
        containsKey(Object): boolean
        
        get(Object): Object
        
        Builder
        
        NullAllowingImmutableSet
        
        Builder
        
        EMPTY: NullAllowingImmutableSet
        
        of(Object[]): NullAllowingImmutableSet<Object>
        
        of(): NullAllowingImmutableSet<Object>
        
        of(Object): NullAllowingImmutableSet<Object>
        
        of(Object, Object): NullAllowingImmutableSet<Object>
        
        of(Object, Object, Object): NullAllowingImmutableSet<Object>
        
        copyOf(Iterable<Object>): NullAllowingImmutableSet<Object>
        
        builder(): Builder<Object>
        
        builder(int): Builder<Object>
        
        elements: Object[]
        
        NullAllowingImmutableSet(Object[]): void
        
        deduplicate(Object[]): Object[]
        
        NullAllowingImmutableSet(Object): void
        
        NullAllowingImmutableSet(Object, Object): void
        
        NullAllowingImmutableSet(Object, Object, Object): void
        
        iterator(): Iterator<Object>
        
        size(): int
        
        ArrayIterator

directory

Java files

com/datastax/

directory

Class files

com/datastax/