Flink CheatSheet
flinkFlink applications code -> JobGraph -> JobManager -> TaskManagers 环境 ExecutionEnvironment StreamExecutionEnvironment TableEnv
flinkFlink applications code -> JobGraph -> JobManager -> TaskManagers 环境 ExecutionEnvironment StreamExecutionEnvironment TableEnv
rack 机架感知 配置相关参数:在core-site.xml配置文件中设置net.topology.node.switch.mapping.impl为org.apache.hadoop.net.ScriptBasedMapping,并指定net.topology.script.
相关概念包括ValueVector、Field、Schema、VectorSchemaRoot以及Table 1234567891011<dependency> <groupId>org.apache.arrow</groupId>
启动默认绑定端口9000 与hdfs冲突,修改tcp_port默认配置文件/etc/clickhouse-server/config.xml自定义配置文件目录 /etc/clickhouse-server/config.d/ clickhouse startclickhouse
Apache name jdk since Version Shiro 11 2.0.0
JDBC连接Maven Repository: com.oceanbase » oceanbase-client (mvnrepository.com) 引入oceanbase-client-1.1.10.jar到spark的jars目录,使用Beeline连接!connnect
About Mermaid | Mermaid 1234567891011graph TD; A-->B; A-->C; B-->D; C-->D; 12345678910111213141516171819202122gra
usageyum install sqlite 123456789101112sqlite3 test.db.header oncreate table stu(id int, name char, sex char , score int);insert into stu va
dim补数时使用历史版本表名增加时间信息 / 增加含时间信息的分区, 通过函数根据时间获取对应的表/分区,默认返回最新版本 以下为表名增加时间信息的示例 1234567891011121314151617181920212223242526def getCha
123456789#JAVAexport JAVA_HOME=/data/soft/jdkexport PATH=$JAVA_HOME/bin:$PATHexport CLASSPATH=$CLASSPATH:.:$JAVA_HOME/lib:$JAVA_HOME/jre/lib