/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ |
H A D | unresolved.scala | 232 def expand(input: LogicalPlan, resolver: Resolver): Seq[NamedExpression] 249 override def expand(input: LogicalPlan, resolver: Resolver): Seq[NamedExpression] = { 256 input.output.filter(_.qualifier.exists(resolver(_, target.get.head))) 264 val attribute = input.resolve(target.get, resolver) 329 override def expand(input: LogicalPlan, resolver: Resolver): Seq[NamedExpression] = expressions
|
/dports/misc/xgboost/xgboost-1.5.1/jvm-packages/xgboost4j/src/main/scala/ml/dmlc/xgboost4j/scala/rabit/handler/ |
H A D | RabitTrackerHandler.scala | 50 val resolver = context.actorOf(Props(classOf[WorkerDependencyResolver], self), "Resolver") constant 163 resolver forward req 197 resolver ! assignedRank 223 resolver forward msg 233 resolver forward req
|
/dports/net/bosh-bootloader/bosh-bootloader-7.2.12/vendor/github.com/aws/aws-sdk-go/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 222 var resolver Resolver 224 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 232 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/graphics/gstreamer1-plugins-libvisual/gst-plugins-base-1.16.2/gst/tcp/ |
H A D | gsttcpserversink.c | 293 GResolver *resolver; in gst_tcp_server_sink_init_send() local 301 resolver = g_resolver_get_default (); in gst_tcp_server_sink_init_send() 304 g_resolver_lookup_by_name (resolver, this->host, in gst_tcp_server_sink_init_send() 311 g_object_unref (resolver); in gst_tcp_server_sink_init_send() 394 g_object_unref (resolver); in gst_tcp_server_sink_init_send()
|
H A D | gsttcpclientsink.c | 286 GResolver *resolver; in gst_tcp_client_sink_start() local 296 resolver = g_resolver_get_default (); in gst_tcp_client_sink_start() 299 g_resolver_lookup_by_name (resolver, this->host, this->cancellable, in gst_tcp_client_sink_start() 306 g_object_unref (resolver); in gst_tcp_client_sink_start() 358 g_object_unref (resolver); in gst_tcp_client_sink_start()
|
/dports/graphics/gstreamer1-plugins-gl/gst-plugins-base-1.16.2/gst/tcp/ |
H A D | gsttcpclientsink.c | 286 GResolver *resolver; in gst_tcp_client_sink_start() local 296 resolver = g_resolver_get_default (); in gst_tcp_client_sink_start() 299 g_resolver_lookup_by_name (resolver, this->host, this->cancellable, in gst_tcp_client_sink_start() 306 g_object_unref (resolver); in gst_tcp_client_sink_start() 358 g_object_unref (resolver); in gst_tcp_client_sink_start()
|
H A D | gsttcpserversink.c | 293 GResolver *resolver; in gst_tcp_server_sink_init_send() local 301 resolver = g_resolver_get_default (); in gst_tcp_server_sink_init_send() 304 g_resolver_lookup_by_name (resolver, this->host, in gst_tcp_server_sink_init_send() 311 g_object_unref (resolver); in gst_tcp_server_sink_init_send() 394 g_object_unref (resolver); in gst_tcp_server_sink_init_send()
|
/dports/www/p5-LWPx-ParanoidAgent/LWPx-ParanoidAgent-1.12/lib/LWPx/ |
H A D | ParanoidAgent.pm | 22 my $resolver = delete $opts{resolver}; 30 $self->{'resolver'} = $resolver; 49 my $res = $self->resolver; 373 sub resolver subroutine
|
/dports/dns/cli53/cli53-0.8.18/vendor/github.com/aws/aws-sdk-go/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 225 var resolver Resolver 227 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 235 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/github.com/aws/aws-sdk-go/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 225 var resolver Resolver 227 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 235 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/security/proftpd-mod_clamav/proftpd-1.3.7c/contrib/mod_dnsbl/ |
H A D | configure.in | 68 dnl Check whether libc provides the DNS resolver symbols (e.g. *BSD/Mac OSX) 79 AC_MSG_CHECKING([for resolver symbols in libc]) 98 AC_MSG_CHECKING([for resolver symbols in libresolv]) 123 AC_MSG_CHECKING([for resolver symbols in /usr/lib64/libresolv.a]) 148 AC_MSG_CHECKING([for resolver symbols in /usr/lib/libresolv.a])
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/aws/aws-sdk-go/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 225 var resolver Resolver 227 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 235 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/sysutils/logtool/logtool-1.3.1/ |
H A D | configure.in | 62 # our resolver stuff 63 AC_ARG_WITH(resolver, optwith 65 --without-resolver Build without the IP address resolution modules 164 AC_MSG_WARN([Warning: unable to find inet_addr - resolver disabled]) 190 AC_MSG_WARN([Warning: unable to find gethostbyaddr - resolver disabled])
|
/dports/sysutils/py-salt/salt-3004.1/salt/ext/tornado/ |
H A D | netutil.py | 455 def initialize(self, resolver, mapping): argument 456 self.resolver = resolver 460 self.resolver.close() 467 return self.resolver.resolve(host, port, *args, **kwargs)
|
/dports/x11/gstreamer1-plugins-x/gst-plugins-base-1.16.2/gst/tcp/ |
H A D | gsttcpserversink.c | 293 GResolver *resolver; in gst_tcp_server_sink_init_send() local 301 resolver = g_resolver_get_default (); in gst_tcp_server_sink_init_send() 304 g_resolver_lookup_by_name (resolver, this->host, in gst_tcp_server_sink_init_send() 311 g_object_unref (resolver); in gst_tcp_server_sink_init_send() 394 g_object_unref (resolver); in gst_tcp_server_sink_init_send()
|
H A D | gsttcpclientsink.c | 286 GResolver *resolver; in gst_tcp_client_sink_start() local 296 resolver = g_resolver_get_default (); in gst_tcp_client_sink_start() 299 g_resolver_lookup_by_name (resolver, this->host, this->cancellable, in gst_tcp_client_sink_start() 306 g_object_unref (resolver); in gst_tcp_client_sink_start() 358 g_object_unref (resolver); in gst_tcp_client_sink_start()
|
/dports/sysutils/docker-registry/distribution-2.7.1/vendor/github.com/aws/aws-sdk-go/aws-sdk-go-1.15.11/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 222 var resolver Resolver 224 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 232 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/databases/litestream/litestream-0.3.6/vendor/github.com/aws/aws-sdk-go/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 225 var resolver Resolver 227 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 235 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/google.golang.org/grpc/xds/internal/balancer/clusterimpl/ |
H A D | clusterimpl.go | 299 cib.ClientConn.ResolveNow(resolver.ResolveNowOptions{}) 339 func (cib *clusterImplBalancer) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOption… 341 newAddrs := make([]resolver.Address, len(addrs)) 348 func (cib *clusterImplBalancer) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address) { 350 newAddrs := make([]resolver.Address, len(addrs))
|
/dports/www/grails/grails-1.3.6/src/java/org/codehaus/groovy/grails/commons/cfg/ |
H A D | ConfigurationHelper.groovy | 98 def resolver = resourceLoader ? 109 mergeInLocations(newConfigObject, defaultsLocations, resolver, classLoader) 116 mergeInLocations(config, locations, resolver, classLoader) 121 …onfigObject config, List locations, PathMatchingResourcePatternResolver resolver, ClassLoader clas… 144 def resource = resolver.getResource(location.toString())
|
/dports/ftp/proftpd-mod_vroot/proftpd-1.3.7c/contrib/mod_dnsbl/ |
H A D | configure.in | 68 dnl Check whether libc provides the DNS resolver symbols (e.g. *BSD/Mac OSX) 79 AC_MSG_CHECKING([for resolver symbols in libc]) 98 AC_MSG_CHECKING([for resolver symbols in libresolv]) 123 AC_MSG_CHECKING([for resolver symbols in /usr/lib64/libresolv.a]) 148 AC_MSG_CHECKING([for resolver symbols in /usr/lib/libresolv.a])
|
/dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/github.com/aws/aws-sdk-go/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 225 var resolver Resolver 227 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 235 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/security/vault/vault-1.8.2/vendor/github.com/aws/aws-sdk-go/aws/endpoints/ |
H A D | endpoints_test.go | 6 resolver := DefaultResolver() 7 enum, ok := resolver.(EnumPartitions) 225 var resolver Resolver 227 resolver = ResolverFunc(func(s, r string, opts ...func(*Options)) (ResolvedEndpoint, error) { 235 resolved, err := resolver.EndpointFor("service", "region", func(o *Options) {
|
/dports/sysutils/terraform-docs/terraform-docs-0.16.0/vendor/google.golang.org/grpc/xds/internal/balancer/clusterimpl/ |
H A D | clusterimpl.go | 299 cib.ClientConn.ResolveNow(resolver.ResolveNowOptions{}) 339 func (cib *clusterImplBalancer) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOption… 341 newAddrs := make([]resolver.Address, len(addrs)) 348 func (cib *clusterImplBalancer) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address) { 350 newAddrs := make([]resolver.Address, len(addrs))
|
/dports/devel/py-pip-tools4/pip-tools-4.5.1/piptools/scripts/ |
H A D | compile.py | 17 from ..resolver import Resolver 383 resolver = Resolver( 391 results = resolver.resolve(max_rounds=max_rounds) 393 hashes = resolver.resolve_hashes(results) 426 unsafe_requirements=resolver.unsafe_constraints,
|