lambda-kafka-function/src/main/java/com/amazonaws/hbase/lambda/KafkaHandler.java [45:50]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private LambdaLogger logger;
	private ObjectMapper mapper = new ObjectMapper();
	private RecordValidator validator = new RecordValidator();
	private String clusterId=System.getenv("CLUSTERID");
	private String tName=System.getenv("TABLENAME");
	private boolean compressionEnabled = Boolean.getBoolean(System.getenv("COMPRESSIONENABLED"));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



lambda-kinesis-function/src/main/java/com/amazonaws/hbase/lambda/KinesisHandler.java [43:48]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private LambdaLogger logger;
	private ObjectMapper mapper = new ObjectMapper();
	private RecordValidator validator = new RecordValidator();
	private String clusterId=System.getenv("CLUSTERID");
	private String tName=System.getenv("TABLENAME");
	private boolean compressionEnabled = Boolean.getBoolean(System.getenv("COMPRESSIONENABLED"));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -