MCPcopy Create free account

hub / github.com/data-integrations/wrangler / functions

Functions1,973 in github.com/data-integrations/wrangler

↓ 1 callersMethoddescription
()
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveInfo.java:96
↓ 1 callersMethoddeserialize
(String type)
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:101
↓ 1 callersMethoddestroy
Invokes each directives destroy method to perform any cleanup required by each individual directive.
wrangler-core/src/main/java/co/cask/wrangler/executor/RecipePipelineExecutor.java:75
↓ 1 callersMethoddrop
Drops a path from the schema to generate a new {@link Schema}. @param schema to be modified. @param path to be removed from {@link Schema}. @return m
wrangler-core/src/main/java/co/cask/functions/DDL.java:115
↓ 1 callersMethodencodeAsJsonGenericRecord
()
wrangler-core/src/test/java/co/cask/directives/parser/ParseAvroTest.java:140
↓ 1 callersMethodensureInitialized
(ExecutorContext context)
wrangler-core/src/main/java/co/cask/directives/lookup/TableLookup.java:76
↓ 1 callersMethodensureJDBCDriverIsAvailable
(Class<? extends Driver> classz, String url)
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:706
↓ 1 callersMethoderror
(Object o)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:160
↓ 1 callersMethoderrors
Returns records that are errored out. @return records that have errored out.
wrangler-core/src/main/java/co/cask/wrangler/executor/RecipePipelineExecutor.java:151
↓ 1 callersMethodextractDomainAndAccount
(String emailId)
wrangler-core/src/main/java/co/cask/directives/transformation/SplitEmail.java:108
↓ 1 callersMethodfindUnionSchema
(Schema unionSchema, @Nullable Object value)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:425
↓ 1 callersMethodfromJsonBytes
(byte[] bytes)
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:423
↓ 1 callersMethodfromWorkspace
Converts the data in workspace into records. @param id name of the workspace from which the records are generated. @return list of records. @throws W
wrangler-service/src/main/java/co/cask/wrangler/service/directive/DirectivesService.java:1170
↓ 1 callersMethodfunctions
()
wrangler-core/src/main/java/co/cask/wrangler/expression/ELRegistration.java:25
↓ 1 callersMethodget
Generates all json paths for the json being passed as a string. @param json string for which json paths need to be extracted. @return list of json pa
wrangler-core/src/main/java/co/cask/wrangler/utils/JsonPathGenerator.java:48
↓ 1 callersMethodget
A value associated with the variable in the transient store. @param name of the variable to be retrieved. @return instance of object of type T.
wrangler-core/src/main/java/co/cask/directives/aggregates/DefaultTransientStore.java:79
↓ 1 callersMethodget
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Service.java:552
↓ 1 callersMethodgetAWSAccessKeyId
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Configuration.java:52
↓ 1 callersMethodgetAWSSecretKey
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Configuration.java:57
↓ 1 callersMethodgetAll
@return A map of directive to {@link UsageEntry}.
wrangler-core/src/main/java/co/cask/wrangler/parser/UsageRegistry.java:131
↓ 1 callersMethodgetBucketWhitelist
(Connection connection)
wrangler-service/src/main/java/co/cask/wrangler/service/gcs/GCSService.java:509
↓ 1 callersMethodgetBuckets
(Storage storage, Set<String> whitelist, int objectLimit)
wrangler-service/src/main/java/co/cask/wrangler/service/gcs/GCSService.java:521
↓ 1 callersMethodgetBuckets
()
wrangler-service/src/main/java/co/cask/wrangler/service/gcs/Buckets.java:36
↓ 1 callersMethodgetCatalog
@return name of the catalog.
wrangler-core/src/main/java/co/cask/directives/lookup/StaticCatalog.java:46
↓ 1 callersMethodgetColumnNumber
()
wrangler-api/src/main/java/co/cask/wrangler/api/SourceInfo.java:40
↓ 1 callersMethodgetCompiledUnit
Returns a <code>RecipeSymbol</code> for the recipe being parsed. This object has all the tokens that were successfully parsed along with source inform
wrangler-core/src/main/java/co/cask/wrangler/parser/RecipeVisitor.java:76
↓ 1 callersMethodgetConfig
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:333
↓ 1 callersMethodgetConfig
Updates the configuration. @param request to gather information of the request. @param responder to respond to the service request.
wrangler-service/src/main/java/co/cask/wrangler/service/directive/DirectivesService.java:1130
↓ 1 callersMethodgetContextName
@return Context name.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:55
↓ 1 callersMethodgetCurrent
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:68
↓ 1 callersMethodgetDPServiceURL
Retrieves the base url from the context and appends method to value to the final url. @param method to be invoked. @return fully formed url to the me
wrangler-transform/src/main/java/co/cask/wrangler/Wrangler.java:516
↓ 1 callersMethodgetDataType
(String value)
wrangler-core/src/main/java/co/cask/wrangler/dq/TypeInference.java:182
↓ 1 callersMethodgetDataType
get data type from the file type. @param fileName @return DataType @throws IOException
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Service.java:563
↓ 1 callersMethodgetDatabases
(Connection connection, String instanceId)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:402
↓ 1 callersMethodgetDatasets
(BigQuery bigQuery, Set<DatasetId> datasetWhitelist)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:548
↓ 1 callersMethodgetDefaultConnection
(List<Connection> connections, ConnectionTypeConfig connectionTypeConfig)
wrangler-service/src/main/java/co/cask/wrangler/service/connections/ConnectionService.java:247
↓ 1 callersMethodgetDescription
(String id)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:242
↓ 1 callersMethodgetDescription
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:52
↓ 1 callersMethodgetDescription
@return Description associated with the directive.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:153
↓ 1 callersMethodgetDescriptor
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:161
↓ 1 callersMethodgetDescriptor
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:367
↓ 1 callersMethodgetDescriptor
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1917
↓ 1 callersMethodgetDirectives
@return List of directives specified by the user.
wrangler-service/src/main/java/co/cask/wrangler/proto/Recipe.java:43
↓ 1 callersMethodgetEnvironment
@return Environment this context is prepared for.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:45
↓ 1 callersMethodgetFromBase
@return Multiplier to be applied when converting from base.
wrangler-core/src/main/java/co/cask/wrangler/dq/ConvertDistances.java:88
↓ 1 callersMethodgetId
@return id of the connection.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:52
↓ 1 callersMethodgetId
@return recipe id.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:71
↓ 1 callersMethodgetIdFromName
(String name)
wrangler-core/src/test/java/co/cask/wrangler/ExperimentTests.java:31
↓ 1 callersMethodgetIdFromName
(String name)
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeService.java:152
↓ 1 callersMethodgetInteger
()
wrangler-core/src/main/java/co/cask/wrangler/expression/ELResult.java:43
↓ 1 callersMethodgetJdbcUrlPattern
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:173
↓ 1 callersMethodgetKeyDeserializer
@return String representation of key deserializer of kafka topic.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:90
↓ 1 callersMethodgetLine
@return Original line that has the syntax error.
wrangler-api/src/main/java/co/cask/wrangler/api/parser/SyntaxError.java:66
↓ 1 callersMethodgetLineNumber
()
wrangler-api/src/main/java/co/cask/wrangler/api/SourceInfo.java:36
↓ 1 callersMethodgetMacros
Extracts all the macros within a string expression. @param expression specifies the expression. @return list of macros present within an expression.
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:660
↓ 1 callersMethodgetName
@return name of the connection.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:59
↓ 1 callersMethodgetName
Given an id, returns the name of the schema. @param id of the schema for which name needs to be returned. @return string value for the id.
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:231
↓ 1 callersMethodgetName
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:48
↓ 1 callersMethodgetName
@return Display name of the directive.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:137
↓ 1 callersMethodgetNextToken
(StringTokenizer tokenizer, String directive, String field, int lineno)
wrangler-core/src/main/java/co/cask/wrangler/parser/MigrateToV2.java:800
↓ 1 callersMethodgetNextVersion
(String id)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:328
↓ 1 callersMethodgetOptionalTokensCount
Returns the count of <code>TokenDefinition</code> that have been specified as optional in the <code>UsageDefinition</code>. @return number of tokens
wrangler-api/src/main/java/co/cask/wrangler/api/parser/UsageDefinition.java:85
↓ 1 callersMethodgetOriginalSource
(ParserRuleContext ctx)
wrangler-core/src/main/java/co/cask/wrangler/parser/RecipeVisitor.java:319
↓ 1 callersMethodgetPeopleCount
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1947
↓ 1 callersMethodgetPeopleList
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1829
↓ 1 callersMethodgetPhonesCount
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:975
↓ 1 callersMethodgetPhonesList
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:53
↓ 1 callersMethodgetPort
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:109
↓ 1 callersMethodgetRecipe
@return {@link Recipe} information associated with this request.
wrangler-service/src/main/java/co/cask/wrangler/proto/RequestV1.java:76
↓ 1 callersMethodgetRegion
()
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Configuration.java:62
↓ 1 callersMethodgetReverseAlias
()
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveConfig.java:79
↓ 1 callersMethodgetSave
@return true if directives need to be saved, else false.
wrangler-service/src/main/java/co/cask/wrangler/proto/Recipe.java:64
↓ 1 callersMethodgetSchemaType
(@Nullable Object value)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:437
↓ 1 callersMethodgetSource
()
wrangler-api/src/main/java/co/cask/wrangler/api/SourceInfo.java:44
↓ 1 callersMethodgetSourceInfo
()
wrangler-api/src/main/java/co/cask/wrangler/api/TokenGroup.java:58
↓ 1 callersMethodgetSpecification
@return schema definition being requested.
wrangler-core/src/main/java/co/cask/wrangler/clients/SchemaInfo.java:94
↓ 1 callersMethodgetStorage
(String projectId, String path)
wrangler-service/src/test/java/co/cask/wrangler/service/gcs/GCSServiceTest.java:99
↓ 1 callersMethodgetTableData
Execute Spanner select query on table with row limit and convert the {@link ResultSet} to {@link Row} and return the list of rows
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:314
↓ 1 callersMethodgetTableSchema
(Connection connection, String instanceId, String databaseId, String tableId)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:261
↓ 1 callersMethodgetTag
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:105
↓ 1 callersMethodgetTag
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:181
↓ 1 callersMethodgetThird
@return Third element of the triplet.
wrangler-api/src/main/java/co/cask/wrangler/api/Triplet.java:55
↓ 1 callersMethodgetTimeUnit
(String unitValue)
wrangler-core/src/main/java/co/cask/directives/parser/ParseTimestamp.java:104
↓ 1 callersMethodgetToBase
@return Multiplier to be applied when converting to base.
wrangler-core/src/main/java/co/cask/wrangler/dq/ConvertDistances.java:81
↓ 1 callersMethodgetTokens
This method returns the list of <code>TokenDefinition</code> that should be used for parsing the directive into <code>Arguments</code>. @return List
wrangler-api/src/main/java/co/cask/wrangler/api/parser/UsageDefinition.java:75
↓ 1 callersMethodgetType
(String id)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:253
↓ 1 callersMethodgetType
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:56
↓ 1 callersMethodgetTypeValue
<code>.tutorial.Person.PhoneType type = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:297
↓ 1 callersMethodgetUsage
Gets the usage of a directive. @param directive for which usage is returned. @return null if not found, else the usage.
wrangler-core/src/main/java/co/cask/wrangler/parser/UsageRegistry.java:108
↓ 1 callersMethodgetValueDeserializer
@return String representation of value deserializer of kafka topic.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:97
↓ 1 callersMethodgetVersions
Given an id, returns all the versions of schema. @param id of schema for which all version of registered schema versions should be returned. @return
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:200
↓ 1 callersMethodgetWorkspaces
Lists all the workspaces registered in the 'default' scope. @return List of workspaces. @throws WorkspaceException throw if there is issue listing wo
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:176
↓ 1 callersMethodgetZonedDateTime
(long ts, TimeUnit unit, ZoneId zoneId)
wrangler-core/src/main/java/co/cask/directives/parser/ParseTimestamp.java:140
↓ 1 callersMethodgetZonedDateTime
(long microTs)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:472
↓ 1 callersMethodguessLocationType
Inspects the location to detect the type of the file. @param path of the file or path to be investigated. @param lookahead Specifies a look a head pa
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/Explorer.java:165
↓ 1 callersMethodhasErrors
()
wrangler-core/src/main/java/co/cask/wrangler/parser/SyntaxErrorListener.java:84
↓ 1 callersMethodhasHeader
Checks if the request has a HTTP header. @param name of the header to be checked. @return true if header is found, false otherwise.
wrangler-service/src/main/java/co/cask/wrangler/RequestExtractor.java:47
↓ 1 callersMethodhasNext
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Reservoir.java:100
↓ 1 callersMethodhasNext
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Bernoulli.java:86
↓ 1 callersMethodhasWorkspace
Checks if a workspace exists. @param id of the workspace to be checked for. @return true if workspace exists, false otherwise. @throws WorkspaceExcep
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:155
← previousnext →401–500 of 1,973, ranked by callers