MCPcopy Create free account

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

Functions3,047 in github.com/data-integrations/wrangler

↓ 1 callersMethodgetName
()
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:124
↓ 1 callersMethodgetNamespaceKeys
(NamespaceSummary namespace)
wrangler-storage/src/main/java/io/cdap/wrangler/store/upgrade/UpgradeStore.java:179
↓ 1 callersMethodgetNextPageToken
Get the nextPageToken returned as part of response to request. @param object resource returned by the request
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/utils/PageRequest.java:112
↓ 1 callersMethodgetOnError
@return if on-error is not specified returns default, else value.
wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java:770
↓ 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/io/cdap/wrangler/api/parser/UsageDefinition.java:83
↓ 1 callersMethodgetOriginalSource
(ParserRuleContext ctx)
wrangler-core/src/main/java/io/cdap/wrangler/parser/RecipeVisitor.java:320
↓ 1 callersMethodgetOutputSchema
(Schema inputSchema, List<DirectiveOutputSchemaGenerator> outputSchemaGenerators)
wrangler-core/src/main/java/io/cdap/wrangler/executor/RecipePipelineExecutor.java:190
↓ 1 callersMethodgetPath
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/SampleSpec.java:72
↓ 1 callersMethodgetPath
(Workspace workspace)
wrangler-service/src/main/java/io/cdap/wrangler/service/bigquery/BigQueryHandler.java:315
↓ 1 callersMethodgetPath
(Workspace workspace)
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:534
↓ 1 callersMethodgetPath
(Workspace workspace)
wrangler-service/src/main/java/io/cdap/wrangler/service/gcs/GCSHandler.java:422
↓ 1 callersMethodgetPath
(Workspace workspace)
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerHandler.java:260
↓ 1 callersMethodgetPath
(Workspace workspace)
wrangler-service/src/main/java/io/cdap/wrangler/service/kafka/KafkaHandler.java:223
↓ 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 callersMethodgetPlugin
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/StageSpec.java:42
↓ 1 callersMethodgetPluginInfo
(String connectorName)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectorArtifactLoader.java:68
↓ 1 callersMethodgetPluginNameSpace
()
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/RemoteDirectiveRequest.java:56
↓ 1 callersMethodgetPrecisionAndScale
extracts precision and scale from schema string
wrangler-core/src/main/java/io/cdap/directives/column/SetType.java:181
↓ 1 callersMethodgetProperties
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:53
↓ 1 callersMethodgetProperties
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/Plugin.java:51
↓ 1 callersMethodgetProperties
@return the project properties.
wrangler-core/src/main/java/io/cdap/wrangler/utils/ProjectInfo.java:57
↓ 1 callersMethodgetRecipe
()
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/RemoteDirectiveRequest.java:44
↓ 1 callersMethodgetRecipeById
(HttpServiceRequest request, HttpServiceResponder responder, @PathParam("context") Str
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/RecipeHandler.java:86
↓ 1 callersMethodgetRecipeId
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/recipe/v2/RecipeId.java:40
↓ 1 callersMethodgetRecipeName
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/recipe/v2/RecipeCreationRequest.java:35
↓ 1 callersMethodgetRecipeParser
(List<String> directives)
wrangler-core/src/test/java/io/cdap/wrangler/lineage/LineageOperationsTest.java:214
↓ 1 callersMethodgetReferenceName
()
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerSpecification.java:46
↓ 1 callersMethodgetRequest
(URL url, Function<InputStream, R> callable)
wrangler-core/src/main/java/io/cdap/wrangler/datamodel/HTTPSchemaLoader.java:138
↓ 1 callersMethodgetReverseAlias
()
wrangler-api/src/main/java/io/cdap/wrangler/api/DirectiveConfig.java:78
↓ 1 callersMethodgetRowIndex
()
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeException.java:44
↓ 1 callersMethodgetSampler
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/FileQueryDetails.java:51
↓ 1 callersMethodgetSave
@return true if directives need to be saved, else false.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/Recipe.java:65
↓ 1 callersMethodgetScanRange
Constructs the range used to query the storage table. @return {@link Range} corresponding to page query parameters.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/utils/PageRequest.java:106
↓ 1 callersMethodgetScanRange
()
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/recipe/RecipePageRequest.java:80
↓ 1 callersMethodgetSchema
()
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerSpecification.java:70
↓ 1 callersMethodgetSchemaForType
(String type, Integer scale, Integer precision)
wrangler-core/src/main/java/io/cdap/wrangler/utils/ColumnConverter.java:341
↓ 1 callersMethodgetSchemaType
(@Nullable Object value)
wrangler-core/src/main/java/io/cdap/wrangler/utils/StructuredRecordJsonConverter.java:373
↓ 1 callersMethodgetScope
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/Artifact.java:47
↓ 1 callersMethodgetServiceFilePath
()
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerSpecification.java:50
↓ 1 callersMethodgetSortByColumnName
Get the table column name mapped to given sortBy value.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/utils/PageRequest.java:100
↓ 1 callersMethodgetSortByField
()
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/recipe/RecipePageRequest.java:135
↓ 1 callersMethodgetSource
()
wrangler-api/src/main/java/io/cdap/wrangler/api/SourceInfo.java:44
↓ 1 callersMethodgetSourceSpecs
Get source specs, contains some hacky way on dealing with the csv parser
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/WorkspaceHandler.java:496
↓ 1 callersMethodgetSpecsInArchive
()
wrangler-core/src/test/java/io/cdap/directives/validation/ValidateStandardTest.java:52
↓ 1 callersMethodgetStorage
(String projectId, String path)
wrangler-service/src/test/java/io/cdap/wrangler/service/gcs/GCSServiceTest.java:99
↓ 1 callersMethodgetSystemDirectives
()
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/RemoteDirectiveRequest.java:48
↓ 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/io/cdap/wrangler/service/spanner/SpannerHandler.java:319
↓ 1 callersMethodgetTableSchema
(Connection connection, String instanceId, String databaseId, String tableId)
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerHandler.java:266
↓ 1 callersMethodgetTag
()
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:128
↓ 1 callersMethodgetTargets
@return a {@link List} of target columns.
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Relation.java:156
↓ 1 callersMethodgetThird
@return Third element of the triplet.
wrangler-api/src/main/java/io/cdap/wrangler/api/Triplet.java:59
↓ 1 callersMethodgetTimeUnit
(String unitValue)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseTimestamp.java:106
↓ 1 callersMethodgetToBase
@return Multiplier to be applied when converting to base.
wrangler-core/src/main/java/io/cdap/wrangler/dq/ConvertDistances.java:81
↓ 1 callersMethodgetType
@return String representation of enum.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionType.java:63
↓ 1 callersMethodgetType
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/Plugin.java:43
↓ 1 callersMethodgetTypeValue
<code>.tutorial.Person.PhoneType type = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:297
↓ 1 callersMethodgetValueDeserializer
@return String representation of value deserializer of kafka topic.
wrangler-service/src/main/java/io/cdap/wrangler/service/kafka/KafkaConfiguration.java:97
↓ 1 callersMethodgetWorkspaceName
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/Workspace.java:53
↓ 1 callersMethodgetZonedDateTime
(long ts, TimeUnit unit, ZoneId zoneId)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseTimestamp.java:152
↓ 1 callersMethodgetZonedDateTime
(long microTs)
wrangler-service/src/main/java/io/cdap/wrangler/service/bigquery/BigQueryHandler.java:468
↓ 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/io/cdap/wrangler/service/explorer/Explorer.java:165
↓ 1 callersMethodhasErrors
()
wrangler-core/src/main/java/io/cdap/wrangler/parser/SyntaxErrorListener.java:84
↓ 1 callersMethodhasNext
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Reservoir.java:100
↓ 1 callersMethodhasWorkspace
Checks if a workspace exists. @param id of the workspace to be checked for. @return true if workspace exists, false otherwise.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:183
↓ 1 callersMethodincrement
Increments the value associated with {@link MutableDouble}
wrangler-core/src/main/java/io/cdap/wrangler/statistics/Measurements.java:50
↓ 1 callersMethodincrement
Increment the {@link MutableDouble} value. @param name name of the measure who's value need to be incremented.
wrangler-core/src/main/java/io/cdap/wrangler/statistics/Measurements.java:67
↓ 1 callersMethodinitialize
Initializes the validator. @throws Exception thrown when there are initialization error.
wrangler-core/src/main/java/io/cdap/wrangler/validator/Validator.java:32
↓ 1 callersMethodinitialize
Initialize should setup this instance to check conformance against a specific set of requirements, for example it can load a specific JSON Schema into
wrangler-core/src/main/java/io/cdap/directives/validation/conformers/Conformer.java:39
↓ 1 callersMethodinvokeHttp
(String url, Map<String, Object> parameters, Map<String, String> head
wrangler-core/src/main/java/io/cdap/directives/external/InvokeHttp.java:176
↓ 1 callersMethodisBoolean
Checks if a value is a boolean or not. @param value representing a boolean. @return true if boolean, else false.
wrangler-core/src/main/java/io/cdap/functions/Types.java:62
↓ 1 callersMethodisDate
Whether the given string value is a date or not. @param value @return true if the value is a date.
wrangler-core/src/main/java/io/cdap/wrangler/dq/DateTimePattern.java:77
↓ 1 callersMethodisHeader
(CSVRecord record)
wrangler-core/src/main/java/io/cdap/directives/parser/CsvParser.java:184
↓ 1 callersMethodisInteger
Checks if a value is a integer or not. @param value representing a integer. @return true if integer, else false.
wrangler-core/src/main/java/io/cdap/functions/Types.java:92
↓ 1 callersMethodisLimitExceeded
()
wrangler-service/src/main/java/io/cdap/wrangler/service/gcs/Buckets.java:40
↓ 1 callersMethodisNumber
(String value)
wrangler-core/src/main/java/io/cdap/wrangler/dq/TypeInference.java:90
↓ 1 callersMethodisNumber
Checks if a value is a number or not. @param value representing a number. @return true if number, else false.
wrangler-core/src/main/java/io/cdap/functions/Types.java:51
↓ 1 callersMethodisPointInside
(Feature feature, Coordinates location)
wrangler-core/src/main/java/io/cdap/functions/GeoFences.java:90
↓ 1 callersMethodisSchemaManagementEnabled
()
wrangler-api/src/main/java/io/cdap/wrangler/api/ExecutorContext.java:81
↓ 1 callersMethodisShownInWrangler
@return Flag indicating whether this record should prevent further wrangling.
wrangler-api/src/main/java/io/cdap/wrangler/api/ErrorRecordBase.java:55
↓ 1 callersMethodisTime
Check if the value passed is a time or not. @param value @return true if the value is type "Time", false otherwise.
wrangler-core/src/main/java/io/cdap/wrangler/dq/DateTimePattern.java:94
↓ 1 callersMethodisUsed
Returns {@code true} if this class has been used to execute JEXL script.
wrangler-core/src/main/java/io/cdap/wrangler/expression/EL.java:63
↓ 1 callersMethodisValid
(String algorithm)
wrangler-core/src/main/java/io/cdap/directives/transformation/MessageHash.java:157
↓ 1 callersMethodisValidLine
Overridable method to validate each line that is returned. @param line the line that is to be validated @return true if valid, false to remove from
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/BoundedLineInputStream.java:112
↓ 1 callersMethodisValidSchemaForValue
(@Nullable Schema schema, Object value)
wrangler-core/src/main/java/io/cdap/wrangler/schema/DirectiveOutputSchemaGenerator.java:113
↓ 1 callersMethodlineage
Returns a Mutation that can be used to generate lineage. @return a instance of {@link Mutation} object used to generate lineage.
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Lineage.java:86
↓ 1 callersMethodlist
(String path)
wrangler-service/src/test/java/io/cdap/wrangler/service/explorer/GCSServiceTest.java:42
↓ 1 callersMethodlistDatabases
Lists all databases. @param request HTTP requests handler. @param responder HTTP response handler.
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:313
↓ 1 callersMethodloadFile
(NamespacedId connectionId, String scope, InputStream inputStream, Dir
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSHandler.java:339
↓ 1 callersMethodloadFile
(NamespacedId connectionId, String scope, InputStream inputStream, S3Obj
wrangler-service/src/main/java/io/cdap/wrangler/service/s3/S3Handler.java:358
↓ 1 callersMethodloadSamplableFile
(NamespacedId connectionId, String scope, InputStream inputSt
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSHandler.java:281
↓ 1 callersMethodloadSamplableFile
(NamespacedId connectionId, String scope, InputStream inputStream,
wrangler-service/src/main/java/io/cdap/wrangler/service/s3/S3Handler.java:300
↓ 1 callersMethodloadSampleableFile
(Namespace namespace, String scope, String path, int lines,
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/FilesystemExplorer.java:233
↓ 1 callersMethodlocationInfo
Returns a map of location info collected. @param location who's information need to be extracted. @return an instance of JSON Object. @throws IOExcep
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/Explorer.java:204
↓ 1 callersMethodltrim
Remove leading characters which may be empty string, space string,\t,\n,\r,\f...any space, break related characters. @param input - the input text. @
wrangler-core/src/main/java/io/cdap/directives/transformation/Trimmer.java:88
↓ 1 callersMethodmaskNumber
(String number, String mask)
wrangler-core/src/main/java/io/cdap/directives/transformation/MaskNumber.java:121
↓ 1 callersMethodmaskShuffle
(String str, int seed)
wrangler-core/src/main/java/io/cdap/directives/transformation/MaskShuffle.java:104
↓ 1 callersMethodmerge
Merges two {@link JsonObject} into a single object. If the keys are overlapping, then the second JsonObject keys will overwrite the first. @param fir
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/DirectivesHandler.java:338
← previousnext →801–900 of 3,047, ranked by callers