piyushnarang

import java.lang.{Double => JDouble, Long => JLong}

import org.apache.flink.api.common.typeinfo.TypeInformation
import org.apache.flink.api.scala._
import org.apache.flink.api.java.tuple.{Tuple2 => JTuple2}
import org.apache.flink.api.java.typeutils.TupleTypeInfo
import org.apache.flink.api.scala.{DataSet, ExecutionEnvironment}
import org.apache.flink.table.api.{TableEnvironment, Types}
import org.apache.flink.table.functions.{AggregateFunction, FunctionContext}
import org.apache.flink.api.scala._

piyushnarang

---
startDelaySeconds: 60
hostPort: 127.0.0.1:9000
ssl: false
lowercaseOutputName: true
lowercaseOutputLabelNames: true
whitelistObjectNames: ["io.prestosql.plugin.hive:type=NamenodeStats,*", "io.prestosql.plugin.hive:type=FileFormatDataSourceStats,*", "io.prestosql.plugin.hive:type=ParquetHiveRecordCursorStats,*", "io.prestosql.plugin.hive.metastore.thrift:type=ThriftHiveMetastore,*", "java.lang:*", "io.prestosql.failureDetector:name=HeartbeatFailureDetector,*", "io.prestosql.execution:name=QueryManager,*", "io.prestosql.execution:name=TaskManager,*", "io.prestosql.execution.executor:name=TaskExecutor,*", "io.prestosql.memory:type=ClusterMemoryPool,*", "io.prestosql.memory:name=ClusterMemoryManager,*","io.prestosql.execution.resourceGroups:type=InternalResourceGroup,*"]
blacklistObjectNames: []
rules:
  - pattern: "java.lang<type=Memory><(.*)>(.+): (.*)"

piyushnarang

# HELP jmx_config_reload_failure_total Number of times configuration have failed to be reloaded.
# TYPE jmx_config_reload_failure_total counter
jmx_config_reload_failure_total 0.0
# HELP jvm_threads_current Current thread count of a JVM
# TYPE jvm_threads_current gauge
jvm_threads_current 374.0
# HELP jvm_threads_daemon Daemon thread count of a JVM
# TYPE jvm_threads_daemon gauge
jvm_threads_daemon 232.0
# HELP jvm_threads_peak Peak thread count of a JVM

piyushnarang

# HELP jmx_config_reload_failure_total Number of times configuration have failed to be reloaded.
# TYPE jmx_config_reload_failure_total counter
jmx_config_reload_failure_total 0.0
# HELP jvm_threads_current Current thread count of a JVM
# TYPE jvm_threads_current gauge
jvm_threads_current 374.0
# HELP jvm_threads_daemon Daemon thread count of a JVM
# TYPE jvm_threads_daemon gauge
jvm_threads_daemon 196.0
# HELP jvm_threads_peak Peak thread count of a JVM

piyushnarang

import java.util.{Iterator => JIterator, UUID}

import cascading.flow.FlowProcess
import cascading.flow.hadoop.HadoopFlowProcess
import cascading.scheme.{Scheme, SinkCall, SourceCall}
import cascading.tap._
import cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator
import cascading.tuple._
import com.twitter.elephantbird.mapred.input.DeprecatedInputFormatWrapper
import com.twitter.elephantbird.mapreduce.input.MapReduceInputFormatWrapper