IBM Streams HBASE integration
Project description
Overview
Provides functions to access HBASE. For example, connect to Hortonworks (HDP). This package exposes the com.ibm.streamsx.hbase toolkit as Python methods.
Sample
A simple Streams application that scans a HBASE table and prints the scanned rows:
from streamsx.topology.topology import * from streamsx.topology.schema import CommonSchema, StreamSchema from streamsx.topology.context import submit import streamsx.hbase as hbase topo = Topology('hbase_scan_sample') scanned_rows = hbase.scan(topo, table_name='sample', max_versions=1 , init_delay=2) scanned_rows.print() cfg = {} cfg[streamsx.topology.context.ConfigParams.SSL_VERIFY] = False submit ('DISTRIBUTED', topo, cfg)
Documentation
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
streamsx.hbase-1.3.2.tar.gz
(6.5 kB
view hashes)
Built Distribution
Close
Hashes for streamsx.hbase-1.3.2-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | cd02a08fb3ea4ecbfd4da0397cfef68a826075ed55a4281886b5fb4ffe989530 |
|
MD5 | f405d2f8deb271d4575a80ba2e5a966d |
|
BLAKE2b-256 | 41afb4aa7f79e8bcdb1b210a343f43c15e13b54d0342e8412b2e24c9415ea98a |