confluo.rpc.schema.Schema Class Reference

Public Member Functions
def	__init__ (self, columns)
def	__str__ (self)
def	record_size (self)
def	columns (self)
def	apply (self, data)
def	pack (self, rec)

Public Attributes
	record_size_
	columns_

Detailed Description

The schema for the data in the atomic multilog.

Constructor & Destructor Documentation

__init__()

def confluo.rpc.schema.Schema.__init__	(		self,
			columns
	)

Initializes the schema to the list of columns passed in.

Args:
    columns: The list of columns that make up the schema.

Member Function Documentation

__str__()

def confluo.rpc.schema.Schema.__str__

(

self

)

Convert to string

Returns:
    String representation of schema

apply()

def confluo.rpc.schema.Schema.apply	(		self,
			data
	)

Adds data to the schema.

Args:
    data: The data to add.
Returns:
    The record.

columns()

def confluo.rpc.schema.Schema.columns

(

self

)

Get list of columns

Returns:
    List of columns

pack()

def confluo.rpc.schema.Schema.pack	(		self,
			rec
	)

Pack data into a record.

Args:
    rec: The record to pack
Returns:
    Packed record

record_size()

def confluo.rpc.schema.Schema.record_size

(

self

)

Get record size in bytes

Returns:
    Record size in bytes

---

The documentation for this class was generated from the following file:

• /Users/anuragk/Work/Projects/Confluo/confluo/pyclient/confluo/rpc/schema.py