Functions — github.com/ambition119/FlinkSQL

hub / github.com/ambition119/FlinkSQL / functions

Functions54 in github.com/ambition119/FlinkSQL

⨍ Functions 54 ◇ Types & classes 19

↓ 8 callersMethodparseSql

(String sql)

blink-sql/src/main/java/ambition/blink/sql/SqlUtils.java:38

↓ 4 callersMethodisContain

(String regex, String sql)

blink-common/src/main/java/ambition/blink/common/utils/BlinkStringUtils.java:112

↓ 4 callersMethodsqlDmlParser

sql中的insert into内容 @param insertSql @return @throws Exception

blink-client/src/main/java/ambition/blink/sql/SqlParserService.java:61

↓ 4 callersMethodsqlTableParser

ddl语句解析 @param ddlSql @return @throws Exception

blink-client/src/main/java/ambition/blink/sql/SqlParserService.java:45

↓ 3 callersMethodsqlViewParser

sql中视图sql解析 @param viewSql @return sql的封装信息类 @throws Exception

blink-client/src/main/java/ambition/blink/sql/SqlParserService.java:53

↓ 2 callersMethodgetSqls

()

blink-common/src/main/java/ambition/blink/common/job/JobParameter.java:44

↓ 2 callersMethodsplitSemiColon

(String str)

blink-common/src/main/java/ambition/blink/common/utils/BlinkStringUtils.java:64

↓ 2 callersMethodsqlFunctionParser

function语句解析 @param funSql @return @throws Exception

blink-client/src/main/java/ambition/blink/sql/SqlParserService.java:37

↓ 1 callersMethodcreateClusterDescriptorWithLogging

( final String flinkConfDir, final Configuration flinkConfiguration, final YarnConfiguration

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:92

↓ 1 callersMethodgetJobGraph

(JobParameter jobParameter, Map<String,String> extParams)

blink-client/src/main/java/ambition/blink/job/JobClient.java:31

↓ 1 callersMethodgetJobName

()

blink-common/src/main/java/ambition/blink/common/job/JobParameter.java:36

↓ 1 callersMethodgetSqlParser

(InputStream stream)

blink-sql/src/main/java/ambition/blink/sql/SqlUtils.java:49

↓ 1 callersMethodgetStreamLocalEnvironmentInfo

(JobParameter jobParameter, Map<String, String> extParams)

blink-stream/src/main/java/ambition/blink/stream/job/impl/StreamJobClientImpl.java:68

↓ 1 callersMethodgetYarnConfiguration

()

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:61

↓ 1 callersMethodisChinese

(String str)

blink-common/src/main/java/ambition/blink/common/utils/BlinkStringUtils.java:121

↓ 1 callersMethodsqlConvert

@param sqlContext sql语句集合 @return sql语句分类对应的集合 @throws Exception

blink-client/src/main/java/ambition/blink/sql/SqlConvertService.java:30

MethodFlinkJobException

()

blink-common/src/main/java/ambition/blink/common/exception/FlinkJobException.java:23

MethodFlinkSqlException

()

blink-common/src/main/java/ambition/blink/common/exception/FlinkSqlException.java:22

MethodJobParameter

()

blink-common/src/main/java/ambition/blink/common/job/JobParameter.java:28

MethodResult

()

blink-common/src/main/java/ambition/blink/common/api/Result.java:26

MethodcreateYarnClusterDescriptor

(org.apache.flink.configuration.Configuration flinkConfiguration)

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:103

MethodfindFile

Locate a file or directory.

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:123

MethodgetCode

()

blink-common/src/main/java/ambition/blink/common/api/Result.java:51

MethodgetJobGraph

(JobParameter jobParameter, Map<String, String> extParams)

blink-stream/src/main/java/ambition/blink/stream/job/impl/StreamJobClientImpl.java:59

MethodgetJobPlan

(JobParameter jobParameter, Map<String, String> extParams)

blink-stream/src/main/java/ambition/blink/stream/job/impl/StreamJobClientImpl.java:53

MethodgetJobPlan

(JobParameter jobParameter, Map<String,String> extParams)

blink-client/src/main/java/ambition/blink/job/JobClient.java:29

MethodgetMessage

()

blink-common/src/main/java/ambition/blink/common/api/Result.java:43

MethodgetResult

()

blink-common/src/main/java/ambition/blink/common/api/Result.java:35

MethodgetStreamLocalEnvironmentInfoV2

(JobParameter jobParameter, Map<String, String> extParams)

blink-stream/src/main/java/ambition/blink/stream/job/impl/StreamJobClientImpl.java:180

MethodgetTableSink

(SqlCreateTable sqlCreateTable, Map<String,String> extParams)

blink-stream/src/main/java/ambition/blink/stream/StreamTableUtils.java:42

MethodgetTableSource

(SqlCreateTable sqlCreateTable, Map<String,String> extParams)

blink-stream/src/main/java/ambition/blink/stream/StreamTableUtils.java:29

MethodgetYarnClient

()

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:87

MethodisApplicationRunning

(ApplicationReport app)

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:65

MethodparseSqlTest

()

blink-sql/src/test/java/ambition/blink/sql/SqlUtilsTest.java:36

Methodrun

()

blink-sql/src/test/java/ambition/blink/sql/SqlUtilsTest.java:31

MethodsetCode

(String code)

blink-common/src/main/java/ambition/blink/common/api/Result.java:55

MethodsetJobName

(String jobName)

blink-common/src/main/java/ambition/blink/common/job/JobParameter.java:40

MethodsetMessage

(String message)

blink-common/src/main/java/ambition/blink/common/api/Result.java:47

MethodsetResult

(T result)

blink-common/src/main/java/ambition/blink/common/api/Result.java:39

MethodsetSqls

(Map<String, List<String>> sqls)

blink-common/src/main/java/ambition/blink/common/job/JobParameter.java:48

MethodsetupYarnClient

()

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:73

MethodshutdownYarnClient

()

blink-job/src/main/java/ambition/blink/yarn/job/YarnBase.java:83

MethodsplitIgnoreQuota

(String str, char delimiter)

blink-common/src/main/java/ambition/blink/common/utils/BlinkStringUtils.java:33

MethodsplitIgnoreQuotaBrackets

(String str, String delimter)

blink-common/src/main/java/ambition/blink/common/utils/BlinkStringUtils.java:28

MethodsqlConvert

(String sqlContext)

blink-sql/src/main/java/ambition/blink/sql/impl/SqlConvertServiceImpl.java:38

MethodsqlConvertTest

()

blink-sql/src/test/java/ambition/blink/sql/impl/SqlConvertServiceImplTest.java:42

MethodsqlDmlParser

(String insertSql)

blink-sql/src/main/java/ambition/blink/sql/impl/SqlParserServiceImpl.java:103

MethodsqlDmlParserTest

()

blink-sql/src/test/java/ambition/blink/sql/impl/SqlParserServiceImplTest.java:77

MethodsqlFunctionParser

(String funSql)

blink-sql/src/main/java/ambition/blink/sql/impl/SqlParserServiceImpl.java:44

MethodsqlFunctionParserTest

()

blink-sql/src/test/java/ambition/blink/sql/impl/SqlParserServiceImplTest.java:36

MethodsqlTableParser

(String ddlSql)

blink-sql/src/main/java/ambition/blink/sql/impl/SqlParserServiceImpl.java:56

MethodsqlTableParserTest

()

blink-sql/src/test/java/ambition/blink/sql/impl/SqlParserServiceImplTest.java:43

MethodsqlViewParser

(String viewSql)

blink-sql/src/main/java/ambition/blink/sql/impl/SqlParserServiceImpl.java:91

MethodsqlViewParserTest

()

blink-sql/src/test/java/ambition/blink/sql/impl/SqlParserServiceImplTest.java:63