Table of Contents - fluent-plugin-datahub-0.0.2 Documentation
Classes and Modules
- DatahubClient
- DatahubHttpClient
- DatahubHttpClientTest
- DatahubProject
- DatahubShard
- DatahubTopic
- Fluent
- Fluent::DatahubOutput
- PutRecordResult
- RecordEntity
- RecordField
- RecordSchema
Methods
- ::new — DatahubClient
- ::new — DatahubHttpClient
- ::new — DatahubProject
- ::new — PutRecordResult
- ::new — RecordEntity
- ::new — RecordField
- ::new — RecordSchema
- ::new — DatahubTopic
- #add_attribute — RecordEntity
- #add_field — RecordSchema
- #check_params — Fluent::DatahubOutput
- #configure — Fluent::DatahubOutput
- #create_project — DatahubClient
- #create_project — DatahubHttpClient
- #create_topic — DatahubHttpClient
- #create_topic — DatahubProject
- #delete_project — DatahubClient
- #delete_project — DatahubHttpClient
- #delete_topic — DatahubHttpClient
- #delete_topic — DatahubProject
- #find_column_index — Fluent::DatahubOutput
- #format — Fluent::DatahubOutput
- #get_active_shard — Fluent::DatahubOutput
- #get_columns_map — RecordEntity
- #get_cursor — DatahubTopic
- #get_encoding — RecordSchema
- #get_field — RecordSchema
- #get_fields — RecordSchema
- #get_name — RecordField
- #get_project — DatahubClient
- #get_project — DatahubHttpClient
- #get_schema — RecordEntity
- #get_shard_cursor — DatahubHttpClient
- #get_shard_id — Fluent::DatahubOutput
- #get_signature — DatahubHttpClient
- #get_stored_column_values — RecordEntity
- #get_topic — DatahubHttpClient
- #get_topic — DatahubProject
- #get_type — RecordField
- #hash_code — Fluent::DatahubOutput
- #list_projects — DatahubHttpClient
- #list_shards — DatahubHttpClient
- #list_shards — DatahubTopic
- #list_topics — DatahubHttpClient
- #list_topics — DatahubProject
- #read_data — DatahubTopic
- #read_data_from_shard — DatahubHttpClient
- #read_data_from_shard_with_cursor — DatahubHttpClient
- #record_to_entity — Fluent::DatahubOutput
- #send_request — DatahubHttpClient
- #set — RecordEntity
- #setBigInt — RecordEntity
- #setBoolean — RecordEntity
- #setDouble — RecordEntity
- #setEncoding — RecordSchema
- #setString — RecordEntity
- #setTimeStamp — RecordEntity
- #set_shard_id — RecordEntity
- #shutdown — Fluent::DatahubOutput
- #start — Fluent::DatahubOutput
- #test — DatahubHttpClientTest
- #to_json — PutRecordResult
- #to_json — RecordEntity
- #to_json — RecordField
- #to_json — RecordSchema
- #update_topic — DatahubHttpClient
- #update_topic — DatahubProject
- #write — Fluent::DatahubOutput
- #write_as_dirty_data — Fluent::DatahubOutput
- #write_data — DatahubTopic
- #write_data_to_topic — DatahubHttpClient
- #write_data_with_retry — Fluent::DatahubOutput